Function Compute:Triggers do Apache RocketMQ autogerenciado

Como funciona

Ao criar um trigger no Function Compute, o serviço gera automaticamente um fluxo de eventos correspondente no EventBridge com base na sua configuração. Visualize os detalhes do trigger no console do Function Compute e os recursos criados automaticamente no console do EventBridge.

Pré-requisitos

Antes de começar, verifique se você possui:

• EventBridge ativado com as permissões necessárias concedidas

• Uma função do Function Compute criada

• Um cluster Apache RocketMQ autogerenciado implantado e acessível. Para implantar rapidamente um cluster e começar a enviar e receber mensagens, consulte o guia de início rápido da sua versão:

  • Apache RocketMQ 5.0: Início rápidoInício rápido

  • Apache RocketMQ 4.x: Início rápidoInício rápido

• Um tópico criado na sua instância do RocketMQ

• Um grupo de consumidores criado na sua instância do RocketMQ

Limitações

• A instância do RocketMQ deve ser acessível pela internet pública ou por uma VPC da Alibaba Cloud.

• Caso o acesso à instância ocorra via VPC, ela deve estar na mesma região da sua função. Certifique-se de que o grupo de segurança permita tráfego de entrada na porta do NameServer do RocketMQ (padrão: 9876).

• A quantidade de triggers do RocketMQ está limitada pela cota de fluxos de eventos do EventBridge. Para mais detalhes, consulte Limites.

Etapa 1: Crie um trigger

1. Faça login no console do Function Compute. No painel de navegação à esquerda, clique em Functions.

2. Na barra de navegação superior, selecione uma região. Na página Functions, clique em na função que deseja gerenciar.

3. Na página de detalhes da função, clique em na aba Trigger e, em seguida, clique em Create Trigger.

4. No painel Create Trigger, configure os parâmetros descritos na tabela a seguir e clique em OK.

Para configurações avançadas, como push configurations, políticas de repetição e filas de mensagens mortas, consulte Recursos avançados de triggers.

Após a criação, o trigger aparece na aba Triggers. Para modificá-lo ou excluí-lo, consulte Gerenciar triggers.

Etapa 2: Configure um evento de teste

O trigger passa as mensagens do RocketMQ para sua função como um array de objetos de evento. Simule uma invocação do trigger configurando manualmente um evento de teste.

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.

2. No painel Configure Test Parameters, selecione Create new test event ou Modify existing test event. Insira um nome para o evento, cole o conteúdo do evento abaixo e clique em OK.

[
  {
    "msgId": "7F0000010BDD2A84AEE70DA49B57****",
    "topic": "testTopic",
    "systemProperties": {
      "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
      "CLUSTER": "DefaultCluster",
      "MIN_OFFSET": "0",
      "TAGS": "TagA",
      "MAX_OFFSET": "128"
    },
    "userProperties": {},
    "body": "Hello RocketMQ"
  }
]

Cada objeto no array representa uma mensagem do RocketMQ. Os campos são descritos abaixo.

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

Após criar o trigger, escreva o código da função para processar as mensagens recebidas. Em produção, o trigger invoca automaticamente a função quando o RocketMQ recebe uma nova mensagem.

1. Na aba Code da página de detalhes da função, escreva seu código no editor e clique em Deploy. O exemplo Node.js a seguir lê o evento e retorna um resultado:

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

2. Clique em Test Function para executar o evento de teste configurado na etapa anterior.

Próximos passos

Além do console do Function Compute, configure e gerencie triggers utilizando:

• Serverless Devs: Consulte Comandos comuns do Serverless Devs

• SDKs: Consulte SDKs

Para modificar ou excluir um trigger existente, consulte Gerenciar triggers.