n8n PostgreSQL Webhook Queue: Cola Resiliente de Alta Concurrencia

Qué resuelve esta Skill

Cuando un webhook recibe ráfagas simultáneas de eventos (por ejemplo, pasarelas de pago durante ventas especiales o registros de pauta masiva), n8n puede agotar los hilos de Node.js o saturar las conexiones hacia APIs de terceros. Esta configuración implementa un patrón de desacoplamiento de dos fases: el webhook receptor responde de inmediato con código HTTP 200 e inserta el payload en una tabla transaccional de PostgreSQL con bloqueo de filas (SKIP LOCKED). Un flujo secundario programado procesa la cola por lotes controlados, eliminando caídas del servidor y garantizando que ningún evento se pierda por saturación.

Requisitos Previos y Entorno

• Instancia de n8n autoalojada (versión 1.40+ en Docker o Kubernetes).
• Base de datos PostgreSQL 14 o superior con extensiones estándar.
• Conexión de credenciales Postgres configurada en el panel de n8n.
• Volumen persistente para logs transaccionales.

Instalación y Configuración Rápida / Despliegue

Ejecuta la siguiente sentencia DDL en tu base de datos PostgreSQL para crear la estructura de la cola transaccional:

CREATE TABLE webhook_events_queue (
    id BIGSERIAL PRIMARY KEY,
    event_type VARCHAR(64) NOT NULL,
    payload JSONB NOT NULL,
    status VARCHAR(20) DEFAULT 'pending',
    attempts INT DEFAULT 0,
    created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
    processed_at TIMESTAMP WITH TIME ZONE
);

CREATE INDEX idx_queue_status_pending ON webhook_events_queue (status, created_at) WHERE status = 'pending';

En el nodo de consumo periódico de n8n, utiliza la consulta con concurrencia segura para reclamar registros sin colisiones entre múltiples workers:

UPDATE webhook_events_queue
SET status = 'processing', attempts = attempts + 1
WHERE id IN (
    SELECT id FROM webhook_events_queue
    WHERE status = 'pending' AND attempts < 3
    ORDER BY created_at ASC
    LIMIT 25
    FOR UPDATE SKIP LOCKED
)
RETURNING id, event_type, payload;

Caso de Uso Recomendado

PyMEs: Centralización de eventos de comercio electrónico (Shopify, WooCommerce y Stripe). El webhook responde al instante a la pasarela evitando reenvíos duplicados por timeout, mientras el procesamiento de inventario y facturación se efectúa en cola ordenada.

Agencias: Integración de formularios de captación de prospectos (Meta Lead Ads y Google Ads) hacia CRMs con límites de tasa estrictos (HubSpot o Salesforce), regulando la velocidad de inserción a 5 solicitudes por segundo.

Límites y Advertencias Técnicas o Ventaja Competitiva

Esta arquitectura elimina por completo la necesidad de contratar servicios externos de mensajería como AWS SQS o RabbitMQ para volúmenes inferiores a 50,000 eventos diarios, reduciendo el costo mensual de infraestructura a cero sobre tu PostgreSQL existente. No obstante, si tu base de datos opera con almacenamiento limitado, debes programar un cron semanal de limpieza para eliminar registros procesados con más de 30 días de antigüedad.

---

Aviso Legal y Descargo de Responsabilidad

Este contenido es de carácter estrictamente informativo, técnico y educativo. El uso, implementación y despliegue de los flujos de automatización, scripts, código, modelos, APIs y herramientas de software analizados en RutaBot.com son bajo la exclusiva responsabilidad de cada usuario. RutaBot no asume responsabilidad por fallas en servidores, costos imprevistos de consumo de tokens o APIs, interrupciones operativas ni vulnerabilidades derivadas de código o servicios de terceros. Todas las marcas comerciales, nombres de software, empresas y logotipos citados pertenecen a sus respectivos titulares y su mención tiene propósitos puramente de divulgación, análisis y uso legítimo (Fair Use / Derecho de Cita). Antes de desplegar automatizaciones o integraciones en entornos de producción críticos, realice pruebas en entornos aislados y audite las políticas de seguridad de su organización.