Comment configurer le plugin RabbitMQ Shovel sur mon agent Amazon MQ ?

Date de la dernière mise à jour : 19/04/2022

Je souhaite déplacer les messages d'un agent sur site vers un agent Amazon MQ pour RabbitMQ à l'aide du plugin RabbitMQ Shovel. Comment configurer mon agent Amazon MQ pour qu'il fonctionne avec le plugin RabbitMQ Shovel ?

Brève description

Pour configurer le plugin RabbitMQ Shovel sur un agent Amazon MQ pour RabbitMQ, vous devez créer un « shovel » dynamique.

Pour créer un « shovel » dynamique pour un agent Amazon MQ pour RabbitMQ, vous pouvez utiliser l'une des méthodes suivantes :

Solution

Remarque : la procédure suivante nécessite deux agents : un agent en amont (sur site ou dans le cloud) et un agent en aval (l’agent Amazon MQ pour RabbitMQ). Vous pouvez configurer un « shovel » dynamique sur un agent en aval ou en amont. Cet exemple de procédure montre comment créer un « shovel » dynamique sur un agent en aval.

Pour créer un « shovel » dynamique sur un agent en aval à l'aide de la console Web RabbitMQ

Important : assurez-vous de spécifier l'URI (Uniform Resource Identifier) pour les files d'attente qui ne sont pas présentes dans l’agent où le « shovel » est créé.

1.    Lancez la console Amazon MQ.

2.    Dans le panneau de navigation de gauche, sélectionnez Agents.

3.    Dans la colonne Nom, choisissez le nom de votre agent en aval.

4.    Dans le panneau Connexions, sélectionnez l'URL répertoriée sous la console Web RabbitMQ. La page de connexion de la console Web RabbitMQ pour votre agent en aval s'ouvre.

5.    Entrez votre Nom d'utilisateur et votre Mot de passe pour votre agent. Ensuite, choisissez Ouvrir une session pour vous connecter à la console Web RabbitMQ.

6.    Dans la console Web RabbitMQ, choisissez l'onglet Administrateur. Ensuite, dans le panneau de navigation de droite, choisissez Gestion des « shovels ».

7.    Choisissez Ajouter un nouveau « shovel ».

8.    Pour Nom, saisissez un nom pour votre « shovel ».

9.    Pour Source, sélectionnez AMQP 0.9.1 dans la liste déroulante. Puis, procédez comme suit :
Dans la liste déroulante à droite de l'URI, sélectionnez File d'attente.
Dans la zone de texte située sous File d'attente, saisissez le nom de la file d'attente source de l’agent en amont.
Pour URI, supprimez le texte amqp:// par défaut et saisissez l'URI de l’agent en amont au format suivant :

amqps://$UPSTREAM_BROKER_USER:$UPSTREAM_BROKER_PASSWORD@$UPSTREAM_BROKER_ENDPOINT:5671

10.    Pour Destination, sélectionnez AMQP 0.9.1 dans la liste déroulante. Puis, procédez comme suit :
Dans la liste déroulante à droite de l'URI, sélectionnez File d'attente.
Dans la zone de texte située sous File d'attente, saisissez le nom de la file d'attente de destination de l’agent en aval.
Pour URI, conservez le texte amqp:// par défaut et saisissez l'URI de l’agent en aval au format suivant :

amqp://$DOWNSTREAM_BROKER_USER:$DOWNSTREAM_BROKER_PASSWORD@$DOWNSTREAM_BROKER_ENDPOINT:5671

11.    Choisissez Ajouter un « shovel ».

Remarque : si les files d'attente source et destination n'existent pas déjà, RabbitMQ les crée automatiquement.

Pour créer un « shovel » dynamique sur un agent aval à l'aide de l'outil de ligne de commande de gestion RabbitMQ

Important : assurez-vous de spécifier l'URI (Uniform Resource Identifier) pour les files d'attente absentes de l’agent où le « shovel » est créé.

Exécutez la commande curl suivante :

curl -u $SHOVEL_BROKER_USER:$SHOVEL_BROKER_PASSWORD \
-X PUT https://$SHOVEL_BROKER_ENDPOINT/api/parameters/shovel/%2f/rmq-lab-shovel \
-H "content-type: application/json" \
-d '{"value": {"src-protocol": "amqp091","src-uri": "amqps://$UPSTREAM_BROKER_USER:$UPSTREAM_BROKER_PASSWORD@$UPSTREAM_BROKER_ENDPOINT:5671","src-queue": "shovel-demo-src-queue","dest-protocol": "amqp091","dest-uri": "amqps://$DOWNSTREAM_BROKER_USER:$DOWNSTREAM_BROKER_PASSWORD@$DOWNSTREAM_BROKER_ENDPOINT:5671","dest-queue": "shovel-demo-dest-queue"}}'

Important : remplacez $SHOVEL_BROKER_USER et $SHOVEL_BROKER_PASSWORD par les informations d'identification de l’agent en aval. Remplacez $SHOVEL_BROKER_ENDPOINT par le point de terminaison de l’agent en aval. Remplacez $UPSTREAM_BROKER_USER et $UPSTREAM_BROKER_PASSWORD par les informations d'identification de l'agent en amont. Remplacez $UPSTREAM_BROKER_ENDPOINT par le point de terminaison de l'agent en amont. Remplacez $DOWNTREAM_BROKER_USER et $DOWNTREAM_BROKER_PASSWORD par les informations d'identification de l'agent en aval. Remplacez $DOWNTREAM_BROKER_ENDPOINT par le point de terminaison de l'agent en aval. Remplacez $SOURCE_QUEUE_NAME par le nom de la file d'attente source dans l’agent en amont. Remplacez $DESTINATION_QUEUE_NAME par le nom de la file d'attente de destination dans l’agent en aval.

Pour tester la configuration

Envoyer un message de test à la file d'attente source de l'agent en amont

1.    Ouvrez la console Web RabbitMQ de l’agent en amont.

Remarque : pour plus d'informations sur la façon d'accéder à la console Web RabbitMQ, consultez Plugin de gestion dans la documentation RabbitMQ.

2.    Cliquez sur l'onglet Files d'attente. Sélectionnez ensuite le nom de la file d'attente source.

3.    Dans le panneau de navigation de gauche, choisissez Publier le message. La section Publier le message s'ouvre.

4.    Dans la zone de texte Charge utile, saisissez un message de test.

Remarque : vous pouvez laisser les zones de texte En-têtes et Propriétés vides.

5.    Cliquez sur le bouton Publier le message. Le message de test est envoyé à la file d'attente source. Si votre « shovel » dynamique est correctement configuré, le message est également consommé par le « shovel » et envoyé à la file d'attente de destination de l'agent en aval.

Vérifiez que le message de test est reçu par la file d'attente de destination de l'’agent en aval

1.    Ouvrez la console Web RabbitMQ de l’agent en aval. Pour obtenir des instructions, reportez-vous aux étapes 1 à 5 de la section Pour créer un « shovel » dynamique sur un agent en aval à l'aide de la console Web RabbitMQ de cet article.

2.    Cliquez sur l'onglet Files d'attente. Choisissez ensuite le nom de la file d'attente de destination.

3.    Dans le panneau de navigation de gauche, sélectionnez Recevoir les messages. La section Recevoir les messages s'ouvre.

4.    Cliquez sur le bouton Recevoir les messages. Si le « shovel » dynamique est correctement configuré, le message de test que vous avez envoyé à la file d'attente source apparaît en tant que valeur de Charge utile.


Cet article vous a-t-il été utile ?


Avez-vous besoin d'aide pour une question technique ou de facturation ?