Recursos · Integración n8n

Integración AMQP Sender n8nAutomatiza AMQP Sender con n8n.

Un flujo de trabajo también habla con un bus de mensajes, no solo con una API. La integración AMQP Sender n8n junta un nodo de envío, con 1 operación, y el AMQP Trigger que escucha una cola o un tema. Encaja en equipos que ya mantienen un broker AMQP 1.0 como ActiveMQ.

Probar la integración AMQP Sender en n8nVer las 1 operaciones

Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth

Por qué automatizar

¿Qué resuelve la integración AMQP Sender n8n?

La integración AMQP Sender n8n conecta un flujo de trabajo con un broker de mensajes que habla AMQP 1.0, el protocolo abierto detrás de sistemas de colas y enrutamiento como ActiveMQ. n8n trae dos nodos para eso. El AMQP Sender publica un mensaje en bruto en una cola o un tema, una vez por item. El AMQP Trigger arranca un flujo cuando llega un mensaje a la cola o al tema que escucha. Los dos usan la misma credencial, llamada AMQP connection.

El camino de ida es el más directo: un flujo recoge lecturas de una máquina, las ordena y se las entrega al AMQP Sender, que publica un mensaje por item en un tema. Es justo lo que hace la plantilla 608, que genera datos de sensores de fábrica y los encola en AMQP; nadie al otro lado del tema necesita hablar con n8n, solo leerlo.

El mismo nodo también sirve para difundir algo que ya circula por un flujo. En la plantilla 762, un nodo consulta la posición de la ISS y el AMQP Sender empuja esas coordenadas a un tema de ActiveMQ; la lógica se traslada sin esfuerzo a un precio, un nivel de inventario o cualquier estado que ya consultes en otro punto del flujo.

En sentido contrario, el AMQP Trigger escucha una cola y convierte cada mensaje en un item que puedes enrutar. A partir de ahí entran los destinos habituales: un documento en MongoDB, un registro en Microsoft SQL, un aviso en Slack cuando alguien tiene que decidir, o un correo con Gmail para el resumen diario.

Conviene tener claro un punto antes de planificar el proyecto: la credencial AMQP abre una conexión con tu broker, no una API HTTP. La diferencia pesa, porque en una aplicación HTTP lo que el nodo no cubre se resuelve con un nodo de petición genérico; aquí no hay ningún recurso genérico al que acudir. El AMQP Sender y el AMQP Trigger son toda la superficie disponible, y lo que exponen marca el límite de lo que el flujo puede hacer.

El broker corre por tu cuenta: n8n espera uno compatible con AMQP 1.0, y ActiveMQ es el ejemplo que cita su documentación. Tampoco esperes que n8n confirme cómo entrega los mensajes al trigger, porque no lo documenta; la única certeza operativa es que el flujo debe permanecer activo para que escuche. La Reseña n8n entra en el detalle del autoalojamiento si estás comparando plataformas para este tipo de fontanería.

Conexión

¿Cómo conectas n8n con tu broker AMQP?

  1. 01

    Levanta un broker AMQP 1.0

    Es el requisito que la documentación de n8n deja por escrito: instalar un broker de mensajes compatible con AMQP 1.0. ActiveMQ es el ejemplo que señala, y la lista AMQP Products recoge las demás opciones. Los dos nodos dialogan con ese broker, así que nada funciona hasta que esté arrancado y accesible desde la máquina que ejecuta n8n. En n8n Cloud, accesible significa accesible desde internet.

  2. 02

    Crea la credencial AMQP

    En n8n, abre el menú Credentials y elige AMQP connection, el único método de autenticación que aceptan estos nodos. Te pedirá cuatro valores. Hostname, la dirección de tu broker de mensajes. Port, el número de puerto que debe usar la conexión. User, el nombre del usuario con el que se establece la conexión, y Password, la contraseña de ese usuario. En ActiveMQ, el valor por defecto documentado para ambos es admin.

  3. 03

    Define el transporte y reutiliza la credencial

    Transport Type es opcional y admite tcp o tls, nada más. Rellénalo cuando tu broker espere un transporte explícito y déjalo vacío en caso contrario. Una credencial se crea una vez y se reutiliza siempre: abre el AMQP Sender o el AMQP Trigger, selecciónala en el desplegable y los dos nodos quedan autenticados. Guarda antes de salir del formulario.

Disparadores

¿Qué arranca el flujo en el lado que escucha?

AMQP Trigger es el nodo que arranca un workflow cuando algo ocurre en AMQP Sender. Activas el workflow y cada evento recibido se convierte en una ejecución.

Lo que ves en n8n

Notas de configuración

01Set up the AMQP TriggerEl AMQP Trigger se suscribe a una cola o a un tema de tu broker y arranca el flujo cuando llega un mensaje. El nodo va por la versión 1 y toma la misma credencial AMQP que el emisor. n8n no documenta ningún mecanismo de entrega para él, así que la regla sobre la que se construye es operativa: el flujo tiene que estar activo para que el trigger escuche.

El AMQP Trigger se suscribe a una cola o a un tema de tu broker y arranca el flujo cuando llega un mensaje. El nodo va por la versión 1 y toma la misma credencial AMQP que el emisor. n8n no documenta ningún mecanismo de entrega para él, así que la regla sobre la que se construye es operativa: el flujo tiene que estar activo para que el trigger escuche.

Parámetros clave

  • Queue / Topic: el nombre de la cola o del tema que se escucha, tal como lo nombra tu broker.
  • Clientname: se deja vacío para suscripciones a temas no duraderas o para colas.
  • Subscription: misma indicación, vacío para suscripciones no duraderas o colas.
  • Container ID: se pasa al backend RHEA como container_id.
Cuándo usarlo
cuando otro sistema ya publica en tu broker y prefieres que n8n reaccione a esos mensajes en lugar de pedirle a ese sistema que llame a n8n.
02Shape the incoming messageUn mensaje que sale de un broker todavía no es un item JSON limpio. Tres opciones del trigger deciden qué recibe el nodo siguiente, y ajustarlas bien ahorra una pila de pasos de limpieza más adelante.

Un mensaje que sale de un broker todavía no es un item JSON limpio. Tres opciones del trigger deciden qué recibe el nodo siguiente, y ajustarlas bien ahorra una pila de pasos de limpieza más adelante.

Parámetros clave

  • JSON Parse Body: convierte el cuerpo en un objeto, para que los nodos siguientes lean campos y no una cadena de texto.
  • Only Body: devuelve solo la propiedad body y descarta el resto del sobre del mensaje.
  • Convert Body To String: pasa el contenido JSON del cuerpo de un array de bytes a cadena, algo que la documentación marca como necesario para Azure Service Bus.
Casos de uso
una cola de eventos de pedido alimenta una tabla. Activa JSON Parse Body y Only Body y el item llega con campos nombrados, listos para mapear a columnas sin ningún nodo de transformación en medio.
03Tune throughput and reconnectionLas opciones restantes deciden cuánto se toma cada vez y qué pasa cuando cae el enlace con el broker. En una cola cargada eso pesa, y se ajusta antes de pasar a producción, no después.

Las opciones restantes deciden cuánto se toma cada vez y qué pasa cuando cae el enlace con el broker. En una cola cargada eso pesa, y se ajusta antes de pasar a producción, no después.

Parámetros clave

  • Messages per Cicle: el número de mensajes que se toman del bus en cada ciclo.
  • Sleep Time: los milisegundos de espera después de cada ciclo.
  • Parallel Processing: procesa los mensajes en paralelo en lugar de uno tras otro.
  • Reconnect: reconecta de forma automática si se corta, con Reconnect Limit como tope de intentos.
Cuándo usarlo
en una cola que se llena más rápido de lo que el flujo la vacía, sube el lote y deja Reconnect activo para que un reinicio del broker no deje al trigger callado.
Acciones

Lo que hace el nodo AMQP Sender

El nodo AMQP Sender expone una operación. Para cada una: el nodo tal como lo configuras en n8n, los campos obligatorios y nuestras notas de campo.

01

Sends a raw-message via AMQP 1.0, executed once per item

execute

Lo que ves en n8n

Notas y casos de uso

La única operación toma el item actual y lo publica como mensaje en bruto en tu broker, una vez por item.

Parámetros clave

  • Queue / Topic: el destino en el broker, escrito como lo espera tu proveedor, por ejemplo topic://sourcename.something.
  • Headers: parámetros de cabecera en JSON plano, enviados como application_properties en los metadatos del mensaje.
  • Send Property: la única propiedad que se envía; vacío, sale el item completo.
  • Data as Object: envía los datos como objeto.
Casos de uso
apunta Queue / Topic hacia tu destino, por ejemplo topic://sourcename.something, y deja Send Property vacío para que salga el item completo como mensaje. Así es como la plantilla 608 convierte cada lectura de sensor en un mensaje sobre el tema.
Necesitas ayuda

¿Necesitas ayuda para automatizar AMQP Sender con n8n?

El equipo te responde directamente.

Cada mensaje lo lee una persona.

FAQ

AMQP Sender y n8n, en claro

01¿La integración AMQP Sender n8n es gratuita?
Sí, del lado de n8n. El AMQP Sender y el AMQP Trigger vienen incluidos con n8n, así que no hay nada que instalar ni coste adicional por los nodos en sí. Vale igual en n8n Cloud, la oferta alojada por n8n, y en una instancia autoalojada con la Community Edition y su licencia Sustainable Use. El flujo se comporta igual en los dos casos. Lo que queda fuera de esa respuesta es el broker: AMQP exige un broker de mensajes compatible con AMQP 1.0, y lo que cueste mantenerlo o contratarlo es un asunto aparte de n8n.
02¿Qué credenciales pide el nodo AMQP Sender?
Un solo tipo de credencial, AMQP connection, compartida por el emisor y el trigger. Pide un Hostname, la dirección de tu broker de mensajes, un Port, el número de puerto que debe usar la conexión, un User, el nombre del usuario con el que se establece la conexión, y el Password de ese usuario. ActiveMQ documenta admin como valor por defecto tanto para User como para Password. Transport Type es opcional y admite tcp o tls. La credencial se crea una vez en el menú Credentials y luego se elige en el desplegable de cada flujo que la necesite.
03¿Qué límites tienen los nodos AMQP en n8n?
El catálogo es estrecho a propósito. El AMQP Sender lleva 1 operación, sobre un único recurso sintético, y el AMQP Trigger escucha sin lista de eventos que marcar. Lo más determinante es estructural: la credencial abre una conexión con tu broker y no una API HTTP, así que la salida habitual no aplica aquí. En una aplicación HTTP recurrirías a un nodo de petición genérico, y para una conexión con un broker no existe equivalente. Los dos nodos AMQP son la superficie con la que trabajas, y mantener el broker AMQP 1.0 sigue siendo cosa tuya.
04¿El AMQP Trigger reacciona en tiempo real?
Nada en el catálogo de n8n permite afirmarlo. El AMQP Trigger no declara mecanismo de entrega alguno, ni webhook, es decir una URL a la que llama un sistema externo, ni polling, es decir una comprobación programada. Cualquier promesa de plazo sería inventada. Lo documentado ya da para trabajar. El nodo escucha mensajes AMQP 1.0 en la cola o el tema indicado en Queue / Topic, el flujo tiene que estar activo para que escuche, y dos opciones describen el ritmo: Messages per Cicle fija cuántos mensajes se toman del bus en cada ciclo y Sleep Time fija los milisegundos de espera después de cada ciclo.
05¿n8n o Make para un broker AMQP?
La decisión se juega en cuatro criterios y ninguna herramienta los gana todos. El alojamiento primero: n8n corre en tus propios servidores con Docker o npm, o en n8n Cloud, mientras que Make solo existe alojado. El control de los datos viene de ahí, porque un n8n autoalojado mantiene los mensajes dentro de tu red, algo que pesa cuando la cola transporta datos de producción. Después el modelo de coste: Make factura por operación, y una cola cargada cambia las cuentas. La lógica visual al final, más cuestión de costumbre que de capacidad. Prueba las dos en un flujo pequeño antes de comprometer un broker.
Hack'celeration Lab

Recibe nuestros tips de integración cada semana.

Sin spam. Cancela cuando quieras.

Misma plataforma

Otros docs útiles sobre este stack.

Ver todas las integraciones