Function Compute:Triggers do RocketMQ

Como funciona

Ao enviar uma solicitação de criação de trigger no console do Function Compute, o serviço cria automaticamente um recurso Event stream no EventBridge com base na configuração do trigger.

Depois que o trigger é criado, você visualize as informações dele no console do Function Compute e os recursos criados automaticamente no console do EventBridge. Quando uma mensagem entra na fila da instância de origem do ApsaraMQ for RocketMQ, o Function Compute é invocado. Em cada invocação, um ou mais eventos de mensagem são enviados à função em lote, conforme sua configuração de agrupamento. Esse comportamento é ideal para cenários de processamento de dados em streaming de ponta a ponta.

Observações de uso

• A instância do ApsaraMQ for RocketMQ que serve como fonte de eventos deve residir na mesma região da função do Function Compute.

• Se o número de fluxos de eventos criados ultrapassar o limite máximo, não será mais possível criar triggers do RocketMQ.

Para consultar os limites de recursos envolvidos na criação de um trigger dentro de uma única conta Alibaba Cloud em uma única região, consulte Limits.

Pré-requisitos

• EventBridge

  • Activate EventBridge and grant permissions to a RAM user

• Function Compute

  • Create an event function

• ApsaraMQ for RocketMQ

  • Activate and grant permissions on ApsaraMQ for RocketMQ

  • Create an instance, a topic, and a group ID

Etapa 1: Criar um trigger

1. Faça login no console do Function Compute, localize a função que deseja gerencie e, na página de detalhes da função, clique em na aba Trigger e clique em em Create Trigger.

2. No painel Create Trigger, defina Trigger Type como ApsaraMQ for RocketMQ, configure os parâmetros descritos na tabela a seguir e clique em em OK.

Para configurações avançadas, como configuração de push, políticas de nova tentativa e filas de mensagens mortas, consulte Advanced features of triggers.

Etapa 2: (Opcional) Configure os parâmetros de entrada da função

A fonte de eventos do ApsaraMQ for RocketMQ é passada para a função como um parâmetro de entrada event. Use seu código para analisar o parâmetro event e processá-lo. É possível passar um event manualmente para a função a fim de simular um evento de trigger e verifique se o código da função está correto.

1. Na aba Code da página de detalhes da função, clique em no ícone ao lado de Test Function e selecione Configure Test Parameters na lista suspensa.

2. No painel Configure Test Parameters, selecione Create New Test Event ou Modify Existing Test Event, insira um nome de evento e o conteúdo do evento e clique em OK.

O formato do event é o seguinte.

[
    {
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"RocketMQ-Function-rocketmq-trigger",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunaccountid":"164901546557****",
    "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
    "aliyunoriginalaccountid":"164901546557****",
    "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
    "aliyunregionid":"cn-chengdu",
    "aliyunpublishaddr":"42.120.XX.XX",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
        },
        "userProperties":{

        },
        "body":"TEST"
    }
    },
    {
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"RocketMQ-Function-rocketmq-trigger",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunaccountid":"164901546557****",
    "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
    "aliyunoriginalaccountid":"164901546557****",
    "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
    "aliyunregionid":"cn-chengdu",
    "aliyunpublishaddr":"42.120.XX.XX",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
        },
        "userProperties":{

        },
        "body":"TEST"
    }
    }
]

A tabela a seguir descreve os parâmetros contidos no campo data. Para os parâmetros definidos na especificação CloudEvents, consulte Overview.

Etapa 3: Escrever e testar o código da função

Após crie o trigger, escreva e teste o código da função para verifique se está correto. Na prática, quando um evento do ApsaraMQ for RocketMQ é entregue ao Function Compute por meio do EventBridge, o trigger invoca a função automaticamente.

1. Na aba Code da página de detalhes da função, escreva seu código no editor de código e clique em em Deploy.

   Este tópico usa o código de função Node.js como exemplo.

   'use strict';
   /*
   To enable the initializer feature,
   implement the initializer function as follows:
   exports.initializer = (context, callback) => {
     console.log('initializing');
     callback(null, '');
   };
   */
   exports.handler = (event, context, callback) => {
     console.log("event: %s", event);
     // Parse the event parameter and process the event.
     callback(null, 'return result');
   }

2. Teste a função.

   Método 1: Se você configurou o parâmetro de entrada da função event para simular a fonte de eventos, clique em em Test Function.

   Método 2: Faça login no console do ApsaraMQ for RocketMQ, localize o tópico da instância do ApsaraMQ for RocketMQ que deseja usar, clique em em Message Send/Receive Test e envie uma mensagem conforme solicitado.

3. Após a conclusão da execução, na aba Code da página de detalhes da função, clique em em Real-time Logs para visualize o resultado.