Aller au contenu principal

Nœud Envoi AWS SQS

Le nœud Envoi AWS SQS permet d'envoyer des messages dans une file d'attente Amazon SQS. Il sert à découpler les systèmes, à créer des files d'attente de traitement et à intégrer des flux avec AWS.

Paramètres​

ParamètreTypeObligatoireDéfautDescription
AppApp❌—Application associée au nœud. Voir Apps.
AWS RegionString✅—Région AWS cible (ex. eu-west-1, us-east-1).
API VersionString❌—Version de l'API SQS utilisée par le nœud.
Identifiant de la clé d'accèsString✅—Access Key ID AWS utilisée pour signer la requête.
Secret de la clé d'accèsString✅—Secret Access Key AWS associée.
Type de file (Standard ou FIFO)Standard / FIFO✅—Type de file à cibler.
URL de la fileString✅—URL complète de la file SQS cible.
Corps du messageJSON❌—Contenu du message envoyé à SQS.
ID du groupe de messagesString❌—Obligatoire côté AWS uniquement pour une file FIFO.
Délai de livraison du message (en secondes)Nombre (secondes)❌—Délai avant disponibilité du message, entre 0 et 900.

AWS Region​

Région AWS à utiliser pour l'appel SQS (ex. eu-west-1, us-east-1).

API Version​

Version de l'API SQS utilisée par le connecteur (optionnel selon la configuration).

Identifiant de la clé d'accès​

Access Key ID AWS utilisée pour authentifier l'appel.

Secret de la clé d'accès​

Secret Access Key associée à l'identifiant d'accès AWS.

Voir aussi : Utiliser les méthodes d'authentification dans les flux.

Type de file (Standard ou FIFO)​

Choisissez le type de file cible :

  • Standard : haut débit, ordre au mieux
  • FIFO : ordre strict et déduplication

URL de la file​

URL de la file d'attente :

  • Format : https://sqs.{region}.amazonaws.com/{account-id}/{queue-name}
  • Supporte les variables Handlebars
  • Une variable de dictionnaire peut fournir l'URL complète : {{dictionaries.aws.ordersQueueUrl}} — dans ce cas, le suffixe .fifo n'est pas imposé par le formulaire
Variable et type de file

Lorsque l'URL est une variable dynamique (dictionnaire ou contexte), le type de file affiché par le formulaire ne peut pas être déduit de l'URL : le suffixe .fifo n'est alors pas forcé. Assurez-vous que la valeur de la variable respecte le format attendu pour le type de file configuré (.fifo pour une file FIFO).

Corps du message​

Corps du message :

  • Format JSON (recommandé)
  • Supporte les variables Handlebars
  • Taille max : 256 KB

ID du groupe de messages​

Identifiant du groupe de messages :

  • Recommandé pour les files FIFO (messageGroupId)
  • Peut être présent selon le type de file configuré

Délai de livraison du message (en secondes)​

Délai avant disponibilité du message côté consommateur :

  • Valeur entre 0 et 900 secondes
  • Permet de retarder la consommation après publication

Entrée​

Le nœud reçoit les données du contexte du flux (déclencheur ou nœuds précédents) et les injecte dans le corps du message et l'URL de la file via les variables Handlebars. Exemple de corps de message :

{ "orderId": "{{context.order.id}}", "status": "pending" }

Sortie​

Le nœud Envoi AWS SQS ne génère aucune variable de contexte : il publie le message dans la file puis le flux continue. Le message est ensuite consommé par le déclencheur AWS SQS ou tout autre consommateur de la file.

Erreurs​

Aucune condition d'échec spécifique n'est documentée pour ce nœud. En cas d'échec d'exécution, ajoutez un nœud On Error au flux pour gérer proprement l'erreur.

Limites​

  • Taille maximale du corps du message : 256 KB.
  • Délai de livraison du message compris entre 0 et 900 secondes.
  • Pour une file FIFO, l'URL de la file doit respecter le format attendu (suffixe .fifo).

Exemple​

Envoyer une commande dans une file SQS : remplissez les champs du nœud :

  • AWS Region : us-east-1
  • Type de file : Standard
  • URL de la file : https://sqs.us-east-1.amazonaws.com/123456789012/orders
  • Corps du message :
{ "orderId": "{{context.order.id}}", "status": "pending" }

Les clés d'accès AWS se sélectionnent via une méthode d'authentification ou se référencent par variables ({{dictionaries.aws.accessKeyId}}).

Voir aussi​