Function Compute:Disparadores de Apache RocketMQ autogestionados

Cómo funciona

Cuando se crea un disparador en Function Compute, el servicio genera automáticamente un event stream correspondiente en EventBridge con base en la configuración especificada. Consulte los detalles del disparador en la consola de Function Compute y los recursos creados automáticamente en la consola de EventBridge.

Requisitos previos

Antes de empezar, asegúrese de contar con lo siguiente:

• EventBridge activado con required permissions granted

• Un Function Compute function created

• Un clúster de Apache RocketMQ autogestionado desplegado y accesible. Para desplegar un clúster rápidamente y comenzar a enviar y recibir mensajes, consulte la guía de inicio rápido de su versión:

  • Apache RocketMQ 5.0: Inicio rápidoInicio rápido

  • Apache RocketMQ 4.x: Inicio rápidoInicio rápido

• Un tema creado en la instancia de RocketMQ

• Un grupo de consumidores creado en la instancia de RocketMQ

Límites

• La instancia de RocketMQ debe ser accesible a través de internet público o desde una Virtual Private Cloud (VPC) de Alibaba Cloud.

• Si se accede a la instancia desde una VPC, esta debe ubicarse en la misma región que la función. Asegúrese de que el security group permita el tráfico entrante en el puerto NameServer de RocketMQ (predeterminado: 9876).

• La cantidad de disparadores de RocketMQ está limitada por la cuota de flujos de eventos de EventBridge. Para obtener más información, consulte Limits.

Paso 1: Crear un disparador

1. Inicie sesión en la consola de Function Compute. En el panel de navegación izquierdo, haga clic en Functions.

2. En la barra de navegación superior, seleccione una región. En la página Functions, haga clic en la función que desea gestionar.

3. En la página de detalles de la función, haga clic en la pestaña Trigger y luego en Create Trigger.

4. En el panel Create Trigger, configure los parámetros descritos en la tabla a continuación y haga clic en OK.

Para configuraciones avanzadas, como ajustes de envío, directivas de reintento y colas de mensajes no entregados, consulte Advanced features of triggers.

Una vez creado, el disparador aparece en la pestaña Triggers. Para modificarlo o eliminarlo, consulte Manage triggers.

Paso 2: Configurar un evento de prueba

El disparador transfiere los mensajes de RocketMQ a la función como una matriz de objetos de evento. Simule una invocación del disparador al configurar manualmente un evento de prueba.

1. En la pestaña Code de la página de detalles de la función, haga clic en el icono junto a Test Function y seleccione Configure Test Parameters.

2. En el panel Configure Test Parameters, seleccione Create new test event o Modify existing test event. Introduzca un nombre para el evento, pegue el contenido del evento que se muestra a continuación y haga clic en 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 de la matriz representa un mensaje de RocketMQ. A continuación se describen los campos.

Paso 3: Escribir y probar el código de la función

Después de crear el disparador, escriba el código de la función para procesar los mensajes entrantes. En producción, el disparador invoca automáticamente la función cuando RocketMQ recibe un mensaje nuevo.

1. En la pestaña Code de la página de detalles de la función, escriba el código en el editor y haga clic en Deploy. El siguiente ejemplo en Node.js lee el evento y devuelve un 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. Haga clic en Test Function para ejecutar el evento de prueba configurado en el paso anterior.

Pasos siguientes

Además de la consola de Function Compute, puede configurar y gestionar los disparadores con las siguientes herramientas:

• Serverless Devs: consulte Comandos comunes de Serverless Devs

• SDK: consulte SDK

Para modificar o eliminar un disparador existente, consulte Manage triggers.