INTÉGRATION RABBITMQ n8n : AUTOMATISER RABBITMQ AVEC N8N
INTÉGRATION RABBITMQ N8N : AUTOMATISER RABBITMQ AVEC N8N
Besoin d'aide pour automatiser Rabbitmq avec n8n ?
Notre équipe vous répond en quelques minutes.
Why automate Rabbitmq with n8n?
L'intégration RabbitMQ n8n met à votre disposition 2 actions pour automatiser vos flux de messages : l'envoi de messages vers des queues ou exchanges, et la suppression d'éléments traités. Ces actions couvrent les besoins essentiels d'interaction avec votre broker de messages depuis n8n.
Gain de temps considérable : Plus besoin de développer des scripts personnalisés pour publier des messages dans RabbitMQ. Configurez des règles intelligentes qui envoient automatiquement des données vers vos queues dès qu'un événement se produit dans vos autres applications. Orchestration simplifiée : Connectez RabbitMQ à plus de 400 applications dans n8n pour créer des pipelines de données sophistiqués. Un nouveau lead dans votre CRM comme HubSpot ? Un message part instantanément vers votre queue de traitement. Nettoyage automatisé : Supprimez automatiquement les messages traités de vos files d'attente pour maintenir des performances optimales sans intervention manuelle.
Exemples de workflows métier concrets que vous pouvez créer :
- Publier automatiquement les commandes e-commerce vers une queue de traitement backend
- Envoyer des notifications push via RabbitMQ quand un ticket support est créé
- Distribuer des tâches de traitement d'images vers des workers via des exchanges fanout
- Déclencher des workflows de facturation asynchrones depuis vos outils de gestion
En automatisant RabbitMQ avec n8n, vous transformez votre broker de messages en hub central de votre architecture événementielle, sans expertise DevOps requise.
How to connect Rabbitmq to n8n?
! 1 stepHow to connect Rabbitmq to n8n?
- 01
Add the node
La connexion de RabbitMQ à n8n s'effectue via les credentials AMQP de votre instance RabbitMQ. Voici comment procéder :Accédez aux credentials n8n : Dans votre workflow n8n, ajoutez un nœud RabbitMQ et cliquez sur "Create new credential" dans le champ "Credential to connect with".Renseignez les informations de connexion : Entrez l'hôte de votre serveur RabbitMQ (ex: localhost ou votre URL cloud), le port (généralement 5672), ainsi que le virtual host si vous en utilisez un.Configurez l'authentification : Saisissez le nom d'utilisateur et le mot de passe de votre compte RabbitMQ. Ces identifiants sont ceux configurés dans votre instance RabbitMQ.Testez la connexion : Cliquez sur "Test" pour vérifier que n8n peut se connecter à votre broker. Un message de succès confirmera que tout est correctement configuré.Sauvegardez et utilisez : Une fois validés, vos credentials sont réutilisables dans tous vos workflows n8n impliquant RabbitMQ.
TIP💡 TIPS : Créez un utilisateur RabbitMQ dédié à n8n avec des permissions limitées aux queues et exchanges nécessaires. Cela renforce la sécurité de votre infrastructure et facilite l'audit des actions automatisées. Pensez également à activer SSL/TLS si votre RabbitMQ est exposé sur internet. Pour aller plus loin, consultez la documentation officielle RabbitMQ sur le contrôle d'accès.- 01
Besoin d'aide pour automatiser Rabbitmq avec n8n ?
Notre équipe vous répond en quelques minutes.
Rabbitmq actions available in n8n
01 Action 01Send a Message to RabbitMQ
Cette action est le cœur de l'intégration RabbitMQ n8n : elle vous permet de publier des messages vers vos queues ou exchanges directement depuis vos workflows. C'est l'action essentielle pour alimenter votre architecture événementielle avec des données provenant de n'importe quelle source connectée à n8n.
Paramètres de configuration :
- Credential to connect with : Menu déroulant requis pour sélectionner vos identifiants RabbitMQ pré-configurés. Vous pouvez créer plusieurs credentials pour différentes instances.
- Operation : Dropdown requis définissant l'action à effectuer. Ici, "Send a Message to RabbitMQ" est sélectionné pour publier des données.
- Mode : Dropdown permettant de choisir entre Queue (envoi direct vers une file d'attente) ou Exchange (publication via un exchange pour distribution). Supporte les valeurs fixes ou dynamiques via expressions.
- Queue / Topic : Champ texte requis où vous spécifiez le nom exact de la queue ou du topic cible. Exemple : "commandes-a-traiter" ou "notifications-users".
- Send Input Data : Interrupteur on/off qui, lorsqu'activé, envoie automatiquement les données de l'étape précédente du workflow comme payload du message. Désactivé, vous devrez définir manuellement le contenu.
- Options : Section extensible pour ajouter des propriétés avancées comme les routing keys, la durabilité des messages ou des headers personnalisés.
Cas d'usage typiques :
- Publier les nouveaux leads CRM vers une queue de qualification automatique
- Envoyer les webhooks reçus vers un exchange pour distribution multi-consommateurs
- Déclencher des jobs de traitement asynchrone depuis des événements Airtable ou Google Sheets
- Alimenter un système de notifications push en temps réel
Quand l'utiliser : Dès que vous avez besoin de découpler le déclencheur d'une action de son exécution, ou de distribuer des tâches vers des workers spécialisés. Parfait pour les architectures microservices et le traitement asynchrone.
02 Action 02Delete From Queue
Cette action permet de supprimer un élément d'une queue RabbitMQ, typiquement après qu'il a été traité par un trigger RabbitMQ dans votre workflow. Elle est essentielle pour maintenir vos files d'attente propres et éviter le retraitement de messages déjà consommés.
Paramètres de configuration :
- Credential to connect with : Menu déroulant requis pour sélectionner le compte RabbitMQ à utiliser. Dans l'exemple, "RabbitMQ account" est sélectionné.
- Operation : Dropdown requis définissant l'action. "Delete From Queue" supprime un item préalablement déclenché par un nœud RabbitMQ Trigger dans le workflow.
- Exchange : Champ texte requis où vous spécifiez le nom de l'exchange associé. Exemple : "exchange-name".
- Type : Dropdown requis définissant le type d'exchange. Options disponibles incluant Fanout (broadcast vers toutes les queues liées), Direct, Topic, ou Headers.
- Routing Key : Champ texte requis pour spécifier la clé de routage utilisée. Exemple : "routing-key".
Cas d'usage typiques :
- Nettoyer automatiquement les messages traités avec succès
- Supprimer les tâches terminées d'une queue de jobs
- Maintenir les performances en évitant l'accumulation de messages obsolètes
Quand l'utiliser : En fin de workflow, après avoir traité avec succès un message reçu via un trigger RabbitMQ. Cette action confirme la bonne réception et le traitement du message, permettant à RabbitMQ de libérer les ressources associées.
Construis ton premier workflow avec notre équipe
Laisse ton email et on t'envoie le catalogue d'automatisations à shipper aujourd'hui.
- Scénarios n8n & Make gratuits à importer
- Docs de setup pas à pas
- Cohorte live + support communauté
Questions fréquentes
L'intégration RabbitMQ n8n est-elle gratuite ?
Oui, l'intégration RabbitMQ est incluse nativement dans n8n, que vous utilisiez la version self-hosted gratuite ou n8n Cloud. Aucun coût supplémentaire n'est appliqué pour utiliser les actions RabbitMQ. Cependant, vous devez disposer de votre propre instance RabbitMQ (auto-hébergée ou via un service cloud comme CloudAMQP, Amazon MQ, etc.). Les coûts éventuels dépendent donc de votre infrastructure RabbitMQ, pas de l'intégration n8n elle-même. Pour les utilisateurs de n8n Cloud, vérifiez que votre plan inclut suffisamment d'exécutions pour vos volumes de messages.Puis-je utiliser RabbitMQ comme trigger dans n8n pour déclencher des workflows ?
Oui, bien que cet article se concentre sur les actions, n8n propose également un nœud RabbitMQ Trigger qui écoute les messages entrants sur vos queues. Ce trigger démarre automatiquement votre workflow dès qu'un nouveau message arrive dans la queue configurée. Combiné avec l'action "Delete From Queue", vous pouvez créer des workflows complets de consommation de messages : réception via trigger, traitement dans n8n, puis suppression du message traité. Cette combinaison est idéale pour implémenter le pattern "worker" dans vos architectures événementielles.Comment gérer les erreurs de connexion RabbitMQ dans mes workflows n8n ?
n8n offre plusieurs mécanismes pour gérer les erreurs de connexion RabbitMQ. Premièrement, activez les retries automatiques dans les paramètres du workflow pour retenter l'envoi en cas d'échec temporaire. Deuxièmement, utilisez un nœud Error Trigger pour capturer les échecs et déclencher des actions correctives (notification Discord, email d'alerte via Gmail, log dans une base de données). Troisièmement, testez régulièrement vos credentials avec l'option "Test" pour détecter les problèmes de connexion avant qu'ils n'impactent vos workflows en production. Pensez aussi à monitorer la santé de votre cluster RabbitMQ indépendamment de n8n.
