Enrutador de admisión de fallos de pipeline por webhook

Cómo funciona

1. 1.Recibir una petición POST en la ruta de webhook data-engineering-pipeline-failure-intake-router-intake con responseMode en responseNode.
2. 2.El nodo Normalize Input copia el body al campo input y añade un valor source fijo.
3. 3.El nodo Validate Input comprueba que el campo input no esté vacío.
4. 4.En la rama verdadera, Forward To Service envía un POST con un parámetro placeholder y autenticación genericCredentialType.
5. 5.Respond Success devuelve {"status":"accepted"} tras el reenvío; Respond Invalid devuelve {"status":"invalid"} en la rama falsa.

Casos de uso

• Punto único de admisión para notificaciones de fallos de pipelines de datos antes de enrutarlas a un sistema externo.
• Rechazo temprano de payloads vacíos o malformados con una respuesta inválida explícita.

Requisitos

• Activar el flujo para que el endpoint de webhook quede disponible.
• Configurar credenciales genericCredentialType en el nodo HTTP Request y sustituir la URL de ejemplo api.example.com.
• Reemplazar el valor REPLACE_WITH_YOUR_VALUE del cuerpo de la petición por el valor real.

Configuración y pruebas en n8n

1. Enviar un POST con body no vacío al webhook y confirmar la respuesta accepted.
2. Enviar un POST con body vacío y confirmar la respuesta invalid sin petición saliente.
3. Revisar el log de ejecución para verificar la rama de validación y el resultado de la llamada HTTP.

Valor del servicio

Ideal como servicio de automatización operativa para conectar sistemas, reducir tareas manuales y acelerar la entrega de resultados a clientes o equipos internos.