Function Compute:Advanced Trigger Features

Envio em lote

O envio em lote agrupa várias mensagens em uma única invocação de função, reduzindo o número de chamadas e melhorando o throughput.

Após ativar o envio em lote, configure os seguintes parâmetros:

Funcionamento do agrupamento em lotes

O sistema envia um lote assim que qualquer uma das condições abaixo for atendida, prevalecendo a que ocorrer primeiro:

• A quantidade de mensagens acumuladas atinge o valor definido em Batch Push Messages.

• O Batch Push Interval expira.

• O tamanho acumulado do body atinge o limite de invocação (32 MB para síncrona, 128 KB para assíncrona).

Exemplos

Exemplo 1 — o intervalo dispara primeiro: Defina Batch Push Messages como 100 (1 KB cada) e Batch Push Interval como 15 s. Se 50 mensagens se acumularem em 15 s, o envio ocorre imediatamente, sem aguardar 100 mensagens.

Exemplo 2 — a contagem de mensagens dispara primeiro: Com as mesmas configurações, se 100 mensagens se acumularem em 10 s, o envio ocorre imediatamente, sem esperar os 15 s.

Exemplo 3 — o limite de tamanho do body dispara primeiro (invocação assíncrona): Configure Batch Push Messages como 100 (2 KB cada), Batch Push Interval como 15 s e Invocation Method como Async Invocation. Quando 100 mensagens se acumularem em 10 s, o tamanho total será de 100 × 2 KB = 200 KB, excedendo o limite assíncrono de 128 KB. O Function Compute divide o lote automaticamente: o primeiro contém 64 mensagens e o segundo, 36 mensagens.

Formato de envio

Selecione o formato dos dados de evento entregues ao ponto de entrada da sua função.

Os exemplos a seguir mostram o payload do evento para cada formato, usando um gatilho de fila do Simple Message Queue (anteriormente MNS) com duas mensagens.

[
    {
        "id": "c2g71017-6f65-fhcf-a814-a396fc8d****",
        "source": "MNS-Function-mnstrigger",
        "specversion": "1.0",
        "type": "mns:Queue:SendMessage",
        "datacontenttype": "application/json; charset=utf-8",
        "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
        "time": "2021-04-08T06:28:17.093Z",
        "aliyunaccountid": "164901546557****",
        "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
        "aliyunoriginalaccountid": "164901546557****",
        "aliyuneventbusname": "MNS-Function-mnstrigger",
        "aliyunregionid": "cn-chengdu",
        "aliyunpublishaddr": "42.120.XX.XX",
        "data": {
            "requestId": "606EA3074344430D4C81****",
            "messageId": "C6DB60D1574661357FA227277445****",
            "messageBody": "TEST"
        }
    },
    {
        "id": "d2g71017-6f65-fhcf-a814-a396fc8d****",
        "source": "MNS-Function-mnstrigger",
        "specversion": "1.0",
        "type": "mns:Queue:SendMessage",
        "datacontenttype": "application/json; charset=utf-8",
        "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
        "time": "2021-04-08T06:28:17.093Z",
        "aliyunaccountid": "164901546557****",
        "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
        "aliyunoriginalaccountid": "164901546557****",
        "aliyuneventbusname": "MNS-Function-mnstrigger",
        "aliyunregionid": "cn-chengdu",
        "aliyunpublishaddr": "42.120.XX.XX",
        "data": {
            "requestId": "606EA3074344430D4C81****",
            "messageId": "C6DB60D1574661357FA227277445****",
            "messageBody": "TEST"
        }
    }
]

[
    {
        "requestId": "606EA3074344430D4C81****",
        "messageId": "C6DB60D1574661357FA227277445****",
        "messageBody": "TEST"
    },
    {
        "requestId": "606EA3074344430D4C81****",
        "messageId": "C6DB60D1574661357FA227277445****",
        "messageBody": "TEST"
    }
]

Quando as novas tentativas são acionadas

Perguntas frequentes

Erros de lógica da função acionam a política de nova tentativa?

Depende do método de invocação. Em invocações síncronas, erros de lógica acionam a política de nova tentativa. Já em invocações assíncronas, esses erros não acionam a política de nova tentativa no nível do gatilho; em vez disso, ativam a política específica de nova tentativa para invocações assíncronas. Para mais detalhes, consulte Políticas de nova tentativa.

Ao avaliar uma nova tentativa acionada por erro de lógica da função, considere a probabilidade de sucesso:

• Se o erro for transitório, implemente a lógica de nova tentativa dentro da própria função em vez de depender da política no nível do gatilho.

• Se o erro for permanente, as novas tentativas não terão êxito e apenas aumentarão o custo. Nesse caso, utilize as configurações de tolerância a falhas e fila de mensagens mortas para tratar a mensagem com falha.

Aumente o throughput definindo o número de threads de consumo concorrente. Atualmente, apenas gatilhos do Kafka permitem configurar a Concurrent Quota. O consumo concorrente no ApsaraMQ for Kafka exige coordenação com as partições do tópico nos seguintes cenários:

• Quantidade de partições do tópico = quantidade de consumos concorrentes: uma thread consome uma partição do tópico.

• Quantidade de partições do tópico > quantidade de consumos concorrentes: vários consumidores concorrentes compartilham o consumo de todas as partições.

• Quantidade de partições do tópico < quantidade de consumos concorrentes: uma thread consome uma partição do tópico e os consumidores excedentes ficam inativos.