EventBridge:Acheminer les événements vers Simple Message Queue (anciennement MNS)

Prérequis

• Activer EventBridge et accorder les autorisations requises.

• Créer une file d'attente.

Créer un flux d'événements

1. Connectez-vous à la console EventBridge. Dans le volet de navigation de gauche, cliquez sur Event Streams.

2. Dans la barre de navigation supérieure, sélectionnez une région et cliquez sur Create Event Stream.

3. Dans le panneau Create Event Stream, définissez le Task Name et la Description, configurez les paramètres suivants, puis cliquez sur Save.

   • Création de tâche

     1. Aux étapes Source, Filtering et Transformation, configurez les règles de filtrage et de transformation des événements, puis cliquez sur Next. Pour plus d'informations sur la configuration de la transformation des événements, consultez la rubrique Utiliser Function Compute pour nettoyer les données de message.

     2. À l'étape Sink, définissez le paramètre Service Type sur Simple Message Queue (anciennement MNS) et configurez les paramètres suivants.

        Parameter	Description	Example
        Queue Name	Sélectionnez une file d'attente SMQ existante.	test
        Enable Base64 Encoding	Recommandé. Si cette option est désactivée, les messages reçus peuvent contenir des caractères illisibles.	Yes
        Message Body	La partie de l'événement à utiliser comme corps du message. Pour plus d'informations, consultez la rubrique Transformation du contenu des événements.	complete event

   • Propriétés de la tâche

     Configurez la stratégie de nouvelle tentative et la file d'attente de messages morts pour le flux d'événements. Pour plus d'informations, consultez la rubrique Nouvelles tentatives et files d'attente de messages morts.

4. Revenez à la page Event Streams. Recherchez votre flux d'événements et cliquez sur Enable dans la colonne Actions.

   Le démarrage du flux d'événements prend entre 30 et 60 secondes. Consultez la progression du démarrage dans la colonne Status de la page Event Streams.

Vérifier les résultats

Vérifiez que les événements sont reçus dans la console SMQ.

1. Connectez-vous à la console Simple Message Queue (anciennement MNS). Dans le volet de navigation de gauche, cliquez sur Queues.

2. Dans la barre de navigation supérieure, sélectionnez une région.

3. Sur la page Queues, recherchez la file d'attente cible et, dans la colonne Actions, choisissez More > Send and Receive Messages.

4. Sur la page Quick Experience for Sending and Receiving Messages, dans la section Receive Message, cliquez sur Receive Message.

   Exemple de message reçu :

   {
       "data":{
          "props":{
               "firstTopic":"topci12****",
               "secondTopic":"",
               "clientId":"GID_MQTT_CONSOLE@@@lmqhb1share01vpc165759566****"
          },
          "body":"Hello World"
       },
       "id":"AC11C08E76C67E7740853B0F604D****",
       "source":"acs:mqtt",
       "specversion":"1.0",
       "type":"mqtt:Topic:SendMessage",
       "datacontenttype":"application/json; charset\u003dutf-8",
       "time":"2022-07-12T03:14:23.447Z",
       "subject":"acs:mq:cn-qingdao:182572506381****:topic/mqtt-cn-2r42rdr****/topci12****",
       "aliyunaccountid":"182572506381****"
   }