Comment configurer le plug-in RabbitMQ Shovel sur mon agent Amazon MQ ?

Brève description

Pour configurer le plugin RabbitMQ Shovel sur un agent Amazon MQ for RabbitMQ, créez un dynamic shovel (sur le site Web de RabbitMQ). Pour créer un dynamic shovel pour un agent Amazon MQ for RabbitMQ, vous pouvez utiliser l'une des options suivantes :

• La console Web RabbitMQ
• L'outil de ligne de commande de gestion RabbitMQ (sur le site Web de RabbitMQ)

La résolution suivante nécessite deux courtiers : un agent en amont et un agent en aval. Vous pouvez utiliser un agent en amont sur site ou basé sur le cloud. Dans ce cas, l'agent en aval est l'agent Amazon MQ for RabbitMQ. Vous pouvez configurer un dynamic shovel sur un agent en aval ou en amont. L'exemple de procédure suivant montre comment créer un dynamic shovel sur un agent en aval.

Remarque : Amazon MQ ne prend pas en charge les agents Amazon MQ privés en tant que destinations de shovels ou de shovels statiques. Pour plus d'informations, consultez la section Plug-in Shovel.

Résolution

Créez un dynamic shovel sur un agent en aval avec 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.    Ouvrez la console Amazon MQ.

2.    Dans le volet de navigation, choisissez Agents.

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

4.    Dans le volet Connexions, sélectionnez l'URL répertoriée sous la console Web RabbitMQ. La page de connexion à 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. Choisissez ensuite Se connecter pour vous connecter à la console Web RabbitMQ.

6.    Dans la console Web RabbitMQ, choisissez l'onglet Admin. Ensuite, dans le volet de navigation de droite, choisissez Gestion des shovels.

7.    Choisissez Ajouter un nouveau shovel.

8.    Dans le champ Nom, saisissez le nom de votre shovel.

9.    Pour Source, sélectionnez AMQP 0.9.1 dans la liste déroulante. Procédez comme suit :
Dans la liste déroulante à droite d'URI, sélectionnez File d'attente.
Dans la zone de texte située sous File d'attente, entrez le nom de la file d'attente source de l'agent en amont.
Pour l'URI, supprimez le texte amqp:// par défaut et entrez 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. Procédez comme suit :
Dans la liste déroulante à droite d'URI, sélectionnez File d'attente.
Dans la zone de texte située sous File d'attente, entrez le nom de la file d'attente de destination de l'agent en aval.
Pour l'URI, conservez le texte amqp:// par défaut et entrez 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 de destination n'existent pas déjà, RabbitMQ les crée automatiquement.

Créez un dynamic shovel sur un agent en aval avec l'outil de ligne de commande RabbitMQ Management

Important : Assurez-vous de spécifier l'identifiant de ressource uniforme (URI) pour les files d'attente qui ne sont pas présentes dans 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.

Tester votre 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 le plug-in de gestion dans la documentation de RabbitMQ.

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

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

4.    Dans la zone de texte Charge utile, entrez 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. Cela envoie le message de test à la file d'attente source. Si vous avez correctement configuré votre dynamic shovel, celui-ci consomme le message et l'envoie à 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, consultez les étapes 1 à 5 de la section Créer un dynamic shovel sur un agent de message en aval à l'aide de la console Web RabbitMQ.

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

3.    Dans le volet de navigation, choisissez Recevoir les messages. La section Recevoir les messages s'ouvre.

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

Informations connexes

Migration d'applications pilotées par messages vers Amazon MQ pour RabbitMQ

Comment configurer le plug-in RabbitMQ Federation sur mon agent Amazon MQ ?