Les files d'attente Simple Message Queue (anciennement MNS), ou SMQ, peuvent servir de sources d'événements pour EventBridge. Cette rubrique explique comment créer une source d'événements personnalisée de type SMQ dans la console EventBridge.
Prérequis
Avant de commencer, assurez-vous d'avoir effectué les actions suivantes :
SMQ
EventBridge
Ajouter une source d'événements SMQ
Connectez-vous à la console EventBridge.
Dans le volet de navigation de gauche, cliquez sur Event Buses.
Dans la barre de navigation supérieure, sélectionnez une région.
Sur la page Event Buses, cliquez sur le nom du bus d'événements à gérer.
Dans le volet de navigation de gauche, cliquez sur Event Sources.
Cliquez sur Add Event Source.
-
Dans le panneau Add Custom Event Source, configurez les paramètres suivants :
Paramètre Description Name Saisissez un nom pour la source d'événements. Description Saisissez une description pour la source d'événements. Event Provider Sélectionnez SMQ dans la liste déroulante. Queue Name Sélectionnez la file d'attente SMQ à utiliser comme source d'événements. Cliquez sur OK.
Exemple d'événement
Lorsqu'un message est envoyé à la file d'attente SMQ, EventBridge génère un objet CloudEvent structuré comme suit :
{
"id": "bffb9722-9c48-407b-9895-b038f78f****",
"source": "acs:mns",
"specversion": "1.0",
"type": "mns:Queue:SendMessage",
"datacontenttype": "application/json; charset=utf-8",
"subject": "acs:mns:cn-hangzhou:123456789098****:queues/zeus",
"time": "2021-04-08T06:28:17.093Z",
"aliyunpublishtime": "2021-04-08T06:30:31.367Z",
"aliyuneventbusname": "mybus",
"data": {
"requestId": "606EA3074344430D4C81****",
"messageId": "C6DB60D1574661357FA227277445****",
"messageBody": "TEST"
}
}
Champs d'enveloppe CloudEvents
Les champs de niveau supérieur sont conformes à la spécification CloudEvents :
| Champ | Type | Description |
|---|---|---|
id |
String | Identifiant unique de l'événement. |
source |
String | Identifiant de la source d'événements. Pour les événements SMQ, la valeur est acs:mns. |
specversion |
String | Version de la spécification CloudEvents. La valeur actuelle est 1.0. |
type |
String | Type d'événement. Pour les messages de file d'attente, la valeur est mns:Queue:SendMessage. |
datacontenttype |
String | Type de média du champ data. |
subject |
String | Chemin d'accès à la ressource au format acs:mns:<region-id>:<account-id>:queues/<queue-name>. |
time |
String | Horodatage de l'événement (ISO 8601). |
aliyunpublishtime |
String | Horodatage de publication de l'événement par EventBridge (ISO 8601). |
aliyuneventbusname |
String | Nom du bus d'événements qui a reçu l'événement. |
Paramètres du champ de données
L'objet data contient les détails du message d'origine :
| Paramètre | Type | Exemple | Description |
|---|---|---|---|
requestId |
String | 606EA3074344430D4C81**** |
ID de requête unique pour l'opération d'envoi. |
messageId |
String | C6DB60D1574661357FA227277445**** |
ID de message unique attribué par la file d'attente. |
messageBody |
String | TEST |
Corps du message envoyé à la file d'attente. |