Création d’un modèle de publication-abonnement Amazon SNS SQS dans Mule 4

MuleSoft — Connecteur SNS

Anypoint Connector pour Amazon SNS (Amazon SNS Connector) fournit une connectivité à l’API Amazon Simple Notification Service (Amazon SNS), vous permettant de créer des applications Web distribuées. Les applications Mule peuvent utiliser Amazon SNS Connector pour envoyer facilement des messages de notification en temps réel aux abonnés intéressés via plusieurs protocoles de livraison.

MuleSoft — Connecteur SQS

Anypoint Connector pour Amazon SQS (Amazon SQS Connector) fournit un moyen simple d’interfacer avec l’API Amazon Simple Queue Service (Amazon SQS), permettant aux utilisateurs Mule de gérer les services de mise en file d’attente SQS sans avoir à interagir directement avec l’API.

Conditions préalables

Avant d’utiliser un connecteur Amazon SNS/SQS, nous avons besoin des éléments suivants :

• Un compte AWS avec accès à Amazon SNS/SQS.
• Informations d’identification AWS pour la gestion des identités et des accès (IAM). Ces informations d’identification comprennent une clé d’accès et une clé secrète.

Démo Application Pub/Sub SNS SQS

Nous devons suivre les étapes ci-dessous:

1. Créez des files d’attente SQS et un sujet SNS.
2. Abonnez le sujet SNS aux files d’attente SQS.
3. Ajoutez des autorisations aux files d’attente pour recevoir des messages de la rubrique.
4. Publier un message dans le sujet.
5. Récupérer les messages de la file d’attente.

Nous utilisons un écouteur HTTP pour invoquer des fonctionnalités telles que la création de files d’attente, la création de rubriques et la publication de messages dans la rubrique. Nous utilisons en outre la file d’attente de création SQS, la rubrique de création SNS, la publication SNS et le connecteur de récupération SQS. Vous trouverez ci-dessous les étapes en détail :

Étape 1 : Créer des files d’attente SQS à abonner et un sujet SNS

PFB les configurations pour SNS et SQS :

Assurez-vous que la connexion de test est réussie.

Nous devons envoyer queueName et le sujet à créer dans le paramètre Uri.

Nous allons créer trois files d’attente cibles : targetQueue1, targetQueue2 et targetQueue3. PFB la demande-réponse de création de file d’attente. Veuillez copier l’URL de file d’attente reçue en réponse. Nous l’utiliserons pour d’autres demandes.

Nous allons créer un sujet SNS – DemoTopic. PFB la demande-réponse de création de sujet. Veuillez copier l’ARN du sujet reçu en réponse. Nous l’utiliserons pour d’autres demandes.

Nous avons créé avec succès les files d’attente et le sujet jusqu’à présent.

Étape 2 : Abonnez le sujet SNS aux files d’attente SQS

Abonnez-vous à SNS Topic Config.

Nous allons nous abonner au sujet DemoTopic pour toutes les files d’attente cibles. Nous devons fournir l’ARN de rubrique et l’ARN de file d’attente dans la charge utile de la demande. Nous pouvons obtenir l’ARN de la file d’attente à partir de l’URL de la file d’attente. PFB la demande-réponse du facteur.

Étape 3 : ajouter des autorisations aux files d’attente pour recevoir des messages d’un sujet

Nous devons fournir les autorisations à la file d’attente SQS pour recevoir des messages d’un sujet abonné. Pour ce faire, nous devons ajouter le sujet à la politique d’accès de la file d’attente. Nous ferons de même pour toutes les files d’attente cibles ou abonnés.

La charge utile de la demande aura l’ARN du sujet, l’ARN de la file d’attente et l’URL de la file d’attente. Nous allons stocker l’URL de la file d’attente de la charge utile dans une variable, car nous devrons la transmettre au connecteur Définir les attributs de la file d’attente à la fin du flux.

Définir la transformation de la politique d’accès.

Convertir en chaîne de transformation :

Nous devons convertir la stratégie en texte, puis l’envoyer au connecteur d’attribut d’ensemble SQS.

Définir les attributs de file d’attente.

PFB la demande-réponse du facteur pour référence.

Maintenant, nous sommes tous prêts à publier un message sur le sujet SNS.

Étape 4 : Publier un message sur le sujet SNS

Charge utile en chaîne de transformation :

Nous devons convertir la charge utile au format texte/simple, puis la publier. PFB la demande-réponse du facteur pour référence.

Le message est publié avec succès dans le sujet SNS.

Étape 5 : Récupérer les messages de la file d’attente

Ce flux recevra le message publié dans la rubrique lorsqu’une file d’attente d’abonnés est configurée sur le connecteur de réception de messages.

Recevoir la configuration des messages :

Message de notification à la transformation JSON :

Sortie de la console de notification de journal :

Transformation de message :

Sortie de la console des messages de journal :

Nous avons maintenant créé avec succès un modèle de publication-abonnement Amazon SNS SQS dans Mule 4.