Function Compute:Triggers de RocketMQ

Funcionamiento

Cuando usted envía una solicitud de creación de trigger en la consola de Function Compute, el servicio crea automáticamente un recurso Event stream en EventBridge a partir de la configuración del trigger.

Una vez creado el trigger, puede consultar su información en la consola de Function Compute y revisar los recursos generados automáticamente en la consola de EventBridge. Cuando un mensaje entra en la cola de la instancia de ApsaraMQ for RocketMQ de origen, se invoca Function Compute. En cada invocación, uno o más eventos de mensaje se envían a la función en un lote, según la configuración de lotes establecida. Este comportamiento es ideal para escenarios de procesamiento de datos de streaming de extremo a extremo.

Notas de uso

• La instancia de ApsaraMQ for RocketMQ que actúa como origen de eventos debe ubicarse en la misma región que la función de Function Compute.

• Si la cantidad de flujos de eventos creados supera el límite máximo, ya no podrá crear triggers de RocketMQ.

Para conocer los límites de los recursos involucrados al crear un trigger dentro de una sola cuenta de Alibaba Cloud en una única región, consulte Limits.

Requisitos previos

• 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

Paso 1: Crear un trigger

1. Inicie sesión en la consola de Function Compute, busque la función que desea gestionar y, en la página de detalles de la función, haga clic en la pestaña Trigger y luego en Create Trigger.

2. En el panel Create Trigger, establezca Trigger Type en ApsaraMQ for RocketMQ, configure los parámetros descritos en la tabla a continuación y haga clic en OK.

Para configuraciones avanzadas, como la configuración de envío, las directivas de reintento y las colas de mensajes no entregados, consulte Advanced features of triggers.

Paso 2: (Opcional) Configurar los parámetros de entrada de la función

El origen de eventos de ApsaraMQ for RocketMQ se pasa a la función como el parámetro de entrada event. Utilice su código para analizar sintácticamente el parámetro event y procesarlo. También puede pasar un event a la función de forma manual para simular un evento de trigger y comprobar si el código de la función es correcto.

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

2. En el panel Configure Test Parameters, seleccione Create New Test Event o Modify Existing Test Event, introduzca un nombre de evento y su contenido, y luego haga clic en OK.

El formato de event es el siguiente.

[
    {
    "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"
    }
    }
]

La tabla a continuación describe los parámetros contenidos en el campo data. Para los parámetros definidos en la especificación CloudEvents, consulte Overview.

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

Después de crear el trigger, escriba y pruebe el código de la función para comprobar que sea correcto. En la práctica, cuando un evento de ApsaraMQ for RocketMQ se entrega a Function Compute a través de EventBridge, el trigger invoca automáticamente la función.

1. En la pestaña Code de la página de detalles de la función, escriba su código en el editor y haga clic en Deploy.

   Este tema utiliza código de función en Node.js como ejemplo.

   '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. Pruebe la función.

   Método 1: Si configuró el parámetro de entrada de la función event para simular el origen de eventos, haga clic en Test Function.

   Método 2: Inicie sesión en la consola de ApsaraMQ for RocketMQ, busque el topic de la instancia de ApsaraMQ for RocketMQ que desea utilizar, haga clic en Message Send/Receive Test y envíe un mensaje siguiendo las indicaciones.

3. Una vez finalizada la ejecución, vaya a la pestaña Code de la página de detalles de la función y haga clic en Real-time Logs para consultar el resultado.