Function Compute:Déclencheurs de file d'attente Simple Message Queue (anciennement MNS)

Contraintes

• La file d'attente Simple Message Queue (anciennement MNS) et la fonction Function Compute doivent résider dans la même région.

• Si votre compte Alibaba Cloud atteint la limite de flux d'événements EventBridge, la création de nouveaux déclencheurs de file d'attente Simple Message Queue (anciennement MNS) est impossible. Pour connaître les limites en vigueur, reportez-vous à Limites.

Prérequis

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

• EventBridge activé avec les permissions appropriées : Activer EventBridge et accorder des permissions à un utilisateur RAM

• Une fonction événementielle Function Compute : Créer une fonction événementielle

• Simple Message Queue (anciennement MNS) activé avec accès autorisé pour les utilisateurs RAM : Activer SMQ et autoriser les utilisateurs RAM à accéder à SMQ

• Une file d'attente créée dans Simple Message Queue (anciennement MNS) : Créer une file d'attente

Étape 1 : Créer un déclencheur

1. Connectez-vous à la console Function Compute et cliquez sur la fonction souhaitée.

2. Dans la page de détails de la fonction, cliquez sur l'onglet Configurations, puis accédez à Triggers et cliquez sur Create Trigger.

3. Renseignez les paramètres du déclencheur. Le champ essentiel est Invocation Method : pour plus de détails, consultez Invocation synchrone et Invocation asynchrone.

   Méthode d'invocation	Comportement	Charge utile maximale	Cas d'usage
   Sync Invocation	Function Compute attend le retour de la fonction avant de remettre l'événement ou le lot suivant	32 Mo	Traitement ordonné ou séquentiel requis
   Async Invocation	Function Compute remet l'événement et passe immédiatement au suivant ; la fonction s'exécute en arrière-plan	128 Ko	Scénarios à haut débit nécessitant une consommation rapide des événements

4. 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, reportez-vous à Fonctionnalités avancées des déclencheurs.

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

Étape 2 : (Facultatif) Configurer les paramètres de test

La fonction reçoit les événements Simple Message Queue (anciennement MNS) sous forme de paramètre event — un tableau d'objets au format CloudEvents. Pour tester votre code sans envoyer de message réel, simulez manuellement l'événement.

1. Dans l'onglet Code, cliquez sur l'icône située à côté de Test Function et sélectionnez Configure Test Parameters.

2. Dans le panneau Configure Test Parameters, cliquez sur Create New Test Event ou Modify Existing Test Event, saisissez un nom d'événement ainsi que le contenu ci-dessous, puis cliquez sur OK.

Exemple de charge utile event :

[
  {
    "id": "c2g71017-6f65-fhcf-a814-a396fc8d****",
    "source": "MNS-Function-mnstrigger",
    "specversion": "1.0",
    "type": "mns:Queue:SendMessage",
    "datacontenttype": "application/json; charset=utf-8",
    "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
    "time": "2021-04-08T06:28:17.093Z",
    "aliyunaccountid": "164901546557****",
    "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
    "aliyunoriginalaccountid": "164901546557****",
    "aliyuneventbusname": "MNS-Function-mnstrigger",
    "aliyunregionid": "cn-chengdu",
    "aliyunpublishaddr": "42.120.XX.XX",
    "data": {
      "requestId": "606EA3074344430D4C81****",
      "messageId": "C6DB60D1574661357FA227277445****",
      "messageBody": "TEST"
    }
  },
  {
    "id": "d2g71017-6f65-fhcf-a814-a396fc8d****",
    "source": "MNS-Function-mnstrigger",
    "specversion": "1.0",
    "type": "mns:Queue:SendMessage",
    "datacontenttype": "application/json; charset=utf-8",
    "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
    "time": "2021-04-08T06:28:17.093Z",
    "aliyunaccountid": "164901546557****",
    "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
    "aliyunoriginalaccountid": "164901546557****",
    "aliyuneventbusname": "MNS-Function-mnstrigger",
    "aliyunregionid": "cn-chengdu",
    "aliyunpublishaddr": "42.120.XX.XX",
    "data": {
      "requestId": "606EA3074344430D4C81****",
      "messageId": "C6DB60D1574661357FA227277445****",
      "messageBody": "TEST"
    }
  }
]

Étape 3 : Écrire et tester la fonction

Après la création du déclencheur, écrivez le code de votre fonction, déployez-le, puis vérifiez le bon fonctionnement de bout en bout.

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

Étapes suivantes

• Modifier ou supprimer un déclencheur : Gérer les déclencheurs

• Configurer les politiques de nouvelle tentative et les files d'attente de lettres mortes : Fonctionnalités avancées des déclencheurs