Function Compute:Déclencheurs Apache RocketMQ auto-gérés

Fonctionnement

Lorsque vous créez un déclencheur dans Function Compute, le service génère automatiquement un flux d'événements correspondant dans EventBridge, conformément à votre configuration. Consultez les détails du déclencheur dans la console Function Compute et les ressources créées automatiquement dans la console EventBridge.

Prérequis

Avant de commencer, assurez-vous de disposer des éléments suivants :

• EventBridge activé avec les permissions requises accordées

• Une fonction Function Compute créée

• Un cluster Apache RocketMQ auto-géré déployé et accessible. Pour déployer rapidement un cluster et commencer à envoyer et recevoir des messages, reportez-vous au guide de démarrage rapide correspondant à votre version :

  • Apache RocketMQ 5.0 : Démarrage rapideDémarrage rapide

  • Apache RocketMQ 4.x : Démarrage rapideDémarrage rapide

• Un topic créé dans votre instance RocketMQ

• Un groupe de consommateurs créé dans votre instance RocketMQ

Limites

• L'instance RocketMQ doit être accessible via Internet public ou depuis un Virtual Private Cloud (VPC) Alibaba Cloud.

• Si l'accès s'effectue depuis un VPC, celui-ci doit se trouver dans la même région que votre fonction. Vérifiez que le groupe de sécurité autorise le trafic entrant sur le port NameServer de RocketMQ (par défaut : 9876).

• Le nombre de déclencheurs RocketMQ est limité par le quota de flux d'événements EventBridge. Pour plus de détails, consultez la rubrique Limites.

Étape 1 : Créer un déclencheur

1. Connectez-vous à la console Function Compute. Dans le volet de navigation de gauche, cliquez sur Functions.

2. Dans la barre de navigation supérieure, sélectionnez une région. Sur la page Functions, cliquez sur la fonction à gérer.

3. Sur la page de détails de la fonction, cliquez sur l'onglet Trigger, puis sur Create Trigger.

4. Dans le panneau Create Trigger, configurez les paramètres décrits dans le tableau suivant, puis cliquez sur OK.

Pour les paramètres avancés tels que les configurations de push, les politiques de nouvelle tentative et les files d'attente de lettres mortes, consultez la rubrique Fonctionnalités avancées des déclencheurs.

Une fois créé, le déclencheur apparaît sous l'onglet Triggers. Pour le modifier ou le supprimer, consultez la rubrique Gérer les déclencheurs.

Étape 2 : Configurer un événement de test

Le déclencheur transmet les messages de RocketMQ à votre fonction sous forme de tableau d'objets d'événement. Simulez une invocation du déclencheur en configurant manuellement un événement de test.

1. Dans l'onglet Code de la page de détails de la fonction, cliquez sur l'icône située à côté de Test Function, puis sélectionnez Configure Test Parameters.

2. Dans le panneau Configure Test Parameters, sélectionnez Create new test event ou Modify existing test event. Saisissez un nom d'événement, collez le contenu de l'événement ci-dessous, puis cliquez sur OK.

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

Chaque objet du tableau représente un message RocketMQ. Les champs sont décrits ci-dessous.

Étape 3 : Écrire et tester le code de la fonction

Après la création du déclencheur, écrivez le code de votre fonction pour traiter les messages entrants. En environnement de production, le déclencheur invoque automatiquement la fonction dès que RocketMQ reçoit un nouveau message.

1. Dans l'onglet Code de la page de détails de la fonction, écrivez votre code dans l'éditeur, puis cliquez sur Deploy. L'exemple Node.js suivant lit l'événement et renvoie un résultat :

   '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. Cliquez sur Test Function pour exécuter l'événement de test configuré à l'étape précédente.

Étapes suivantes

Outre la console Function Compute, configurez et gérez les déclencheurs à l'aide des outils suivants :

• Serverless Devs : Consultez la rubrique Commandes Serverless Devs courantes

• SDK : Consultez la rubrique SDK

Pour modifier ou supprimer un déclencheur existant, consultez la rubrique Gérer les déclencheurs.