Intégration RabbitMQ n8nAutomatiser RabbitMQ avec n8n.
Une file de messages devient lisible dès que n8n se branche des deux côtés. L'intégration RabbitMQ n8n, c'est 2 opérations de nœud, publier un message et en supprimer un d'une file, plus un trigger qui consomme une file et lance une exécution par message reçu.
Avis vérifiés sur Trustpilot · Agence IA, automatisation & growth
Que couvre vraiment l'intégration RabbitMQ n8n ?
RabbitMQ est un courtier de messages : un système dépose des messages dans une file, un autre les récupère quand il est prêt à travailler. L'intégration n8n place un workflow, c'est-à-dire une automatisation, de chaque côté de cette file. Le nœud RabbitMQ publie un message vers une file ou vers un exchange, et sait aussi supprimer un message d'une file. Le RabbitMQ Trigger tient le rôle du consommateur : chaque message qui arrive sur la file devient une exécution.
Le premier cas, c'est la question du rythme. Un workflow qui collecte de la donnée à intervalle régulier va souvent plus vite que ce qui doit la ranger derrière. En publiant chaque résultat dans un topic RabbitMQ, le workflow suivant vide la file à sa vitesse, puis écrit ligne par ligne dans Google Sheets. La bibliothèque de templates n8n montre le motif avec des positions de satellite envoyées vers un topic (workflow 844).
Deuxième cas : l’aiguillage. La bibliothèque de templates n8n montre des événements d’onboarding client publiés dans RabbitMQ avec une clé de routage, récupérés par un petit workflow consommateur qui met le message en forme avec un nœud Code et envoie l’alerte par Gmail (template 15316). Un workflow publie, un consommateur dédié réagit, plutôt qu’un seul workflow qui gonfle de branche en branche.
Troisième cas, la diffusion. Un exchange de type fanout recopie un message publié vers toutes les files qui lui sont liées. Un seul message « commande payée » alimente donc à la fois un workflow de reporting qui consolide dans Microsoft SQL et un workflow qui prépare l'email client. Tu publies une fois, le courtier s'occupe de la copie.
Les limites, sans détour. Le nœud embarque 2 opérations, pas une de plus : pas de liste des files, pas de gestion des utilisateurs, pas de lecture d'un message en dehors du trigger. Et le credential ouvre une connexion AMQP vers le courtier, pas une API HTTP. La parade habituelle qui consiste à poser un nœud HTTP Request pour rattraper une opération manquante ne s'applique donc pas ici. Ce que le nœud et le trigger n'exposent pas ne se fait pas depuis n8n, ça reste du côté de RabbitMQ.
Autant le dire : cette intégration s'adresse aux équipes qui font déjà tourner un courtier et veulent poser de l'automatisation autour. Si les files sont un terrain neuf pour les personnes qui vont maintenir ces workflows, la Formation n8n couvre les bases de trigger et de credential que cette page suppose acquises, et l'Avis n8n replace l'outil dans son contexte.
Comment brancher n8n sur un courtier RabbitMQ ?
- 01
Indiquer l'adresse du courtier
Dans n8n, ouvre le menu Credentials et crée un credential RabbitMQ, c'est-à-dire un jeu d'identifiants enregistré une fois et réutilisable. La seule méthode proposée est la connexion utilisateur. Commence par la machine : Hostname reçoit l'hôte qui fait tourner RabbitMQ, Port reçoit le port que la connexion doit utiliser. Tous les nœuds RabbitMQ ajoutés ensuite proposeront ce credential dans leur liste déroulante.
- 02
Renseigner le compte et le vhost
User est le compte avec lequel la connexion se connecte, Password son mot de passe. RabbitMQ livre un compte
guestdont le mot de passe par défaut estguest, et recommande un autre utilisateur en production. Vhost attend l'hôte virtuel à utiliser, une façon de découper un même courtier en espaces isolés ; l'hôte virtuel par défaut est/. - 03
Activer SSL si le courtier l'exige
L'interrupteur SSL décide si la connexion est chiffrée. Une fois activé, Passwordless indique si la connexion par certificat utilise le mécanisme SASL EXTERNAL ou se passe de mot de passe. Dans ce dernier cas, colle le Client Certificate et le Client Key sous forme de texte, avec la Passphrase. CA Certificates reçoit le texte des certificats d'autorité à reconnaître.
Qu'écoute le RabbitMQ Trigger ?
RabbitMQ Trigger est le nœud qui démarre un workflow quand quelque chose se passe dans RabbitMQ. Tu actives le workflow et chaque événement reçu devient une exécution.
Ce que tu vois dans n8n
Notes de configuration
01Configure the RabbitMQ Trigger
Aucune liste d'événements à cocher ici. Le trigger consomme une file et produit une exécution par message qui y arrive. Enregistre le workflow, puis active-le : un workflow inactif n'écoute rien.
Paramètres clés
- Queue / Topic : le nom de la file à lire, écrit exactement comme il existe sur le courtier, par exemple
commandes.creees. - Delete From Queue When : dans Options, ce réglage fixe le moment de l'accusé de réception, donc si le message quitte la file dès que n8n le reçoit ou une fois l'exécution terminée.
- Parallel Message Processing Limit : le nombre maximal d'exécutions simultanées. La valeur
-1retire le plafond.
02Shape the messages the trigger returns
Un message arrive sous forme de contenu brut. La collection Options décide de ce que n8n transmet au nœud suivant et de la manière dont la file est déclarée.
Paramètres clés
- JSON Parse Body : transforme le corps du message en objet, ce qui rend ses champs exploitables en
{{ $json.champ }}plus loin dans le workflow, au lieu d'une seule chaîne de texte. - Only Content : ne renvoie que la propriété de contenu, sans l'enveloppe de livraison qui l'entoure.
- Content Is Binary : enregistre le contenu en binaire, le réglage des messages qui transportent un fichier plutôt que du texte.
- Assert Queue, Durable, Exclusive, Auto Delete Queue : vérifier que la file existe avant de lire, la conserver après un redémarrage du courtier, la limiter à cette connexion, ou la supprimer quand plus aucun consommateur ne l'écoute.
- Binding, Arguments, Headers : ajouter un binding à la file, et y joindre des arguments ou des en-têtes.
Que sait faire le nœud RabbitMQ ?
Le nœud RabbitMQ expose 2 opérations. Pour chacune : le nœud tel que tu le configures dans n8n, les champs obligatoires, et nos notes de terrain.
Send a Message to RabbitMQ
sendMessageCe que tu vois dans n8n
Notes & cas d'usage
Publie un message vers une file ou vers un exchange.
Paramètres clés
- Queue / Topic : le nom de la file de destination.
- Exchange et Type : passer par un exchange de type
direct,topic,headersoufanout, selon la répartition voulue. - Routing Key : la clé de routage sur laquelle l'exchange fait sa correspondance.
- Send Input Data : envoie l'item entrant en JSON ; désactivé, tu rédiges toi-même la charge dans Message.
- Alternate Exchange : dans Options, un exchange de repli pour les messages que celui-ci ne peut router vers aucune file.
Delete From Queue
deleteMessageCe que tu vois dans n8n
Notes & cas d'usage
Retire un message d'une file au lieu d'y publier. L'opération travaille donc sur une entrée existante plutôt que d'en ajouter une.
Paramètres clés
- Queue / Topic : la file sur laquelle l'opération agit.
- Exchange et Type : nommer l'exchange quand la cible passe par lui, avec les mêmes choix
direct,topic,headersetfanout. - Routing Key : la clé de routage attachée au message.
- Message : le message visé, souvent repris du trigger avec une expression du type
{{ $json.content }}.
Besoin d'aide pour automatiser RabbitMQ avec n8n ?
L'équipe te répond directement.
Chaque message est lu par une personne.
