Sistema de Recordatorios de Tareas Multi-canal Basado en Base de Datos - Flujo de trabajo de n8n

Administradores de sistemas y desarrolladores que crean microservicios de notificación.
Equipos que necesitan una programación de recordatorios centralizada y configurable.
Usuarios que buscan plantillas robustas y complejas de n8n para comunicación multicanal.
Cualquiera que necesite una solución de automatización resiliente respaldada por bases de datos usando n8n.

Esta robusta automatización resuelve el desafío de crear un sistema de notificación de tareas multicanal y fiable. Utilizando un flujo de trabajo de n8n, las tareas se ingieren a través de un webhook dedicado y se almacenan de forma segura en una base de datos PostgreSQL. Una parte crucial de este sistema es el disparador (trigger) programado de n8n que comprueba periódicamente las tareas pendientes. La principal propuesta de valor reside en su capacidad de enrutamiento dinámico, que permite al usuario especificar su canal de comunicación preferido —Correo electrónico, Slack o Telegram— al crear la tarea. Esta arquitectura avanzada de flujo de trabajo de n8n garantiza que los recordatorios de misión crítica se entreguen de forma fiable allí donde sea más probable que se vean, lo que lo convierte en una adición muy valiosa a cualquier colección de automatización de n8n. Esta plantilla muestra las mejores prácticas para usar el nodo PostgreSQL de n8n para la gestión de datos y el control del flujo dentro de un flujo de trabajo de n8n.

El flujo de trabajo de n8n se estructura en dos componentes principales: Ingesta de Tareas y Distribución de Recordatorios.

1. Ingesta de Tareas (Disparador Webhook): El proceso comienza cuando una aplicación externa llama al disparador de n8n Webhook - Receive Task, enviando una carga útil JSON que contiene los detalles de la tarea.


2. Validación: El nodo de n8n Validate Input impone restricciones, asegurando que se proporcionen userId, taskName y reminderTime. Un fallo aquí da como resultado una Error Response inmediata.


3. Persistencia: Las tareas válidas pasan al nodo de n8n Save Task to Database, donde se almacenan en PostgreSQL con un estado 'pending' (pendiente). Una operación exitosa envía una Success Response positiva.


4. Distribución de Recordatorios (Disparador Programado): La segunda mitad de este flujo de trabajo de n8n es iniciada por el disparador de n8n Schedule Trigger - Every 5 Minutes, que se ejecuta según una planificación cron (/5 *).


5. Consulta a la Base de Datos: El nodo de n8n Fetch Due Tasks consulta a PostgreSQL buscando tareas pendientes donde el reminder_time se acerca o ya ha pasado.


6. Control de Flujo: El nodo de n8n Check Tasks Exist asegura que el flujo solo continúe si se recuperaron registros. Luego, el flujo divide los registros usando el nodo Split Into Items de n8n para procesar cada tarea de forma independiente.


7. Enrutamiento por Canal: El nodo de n8n Route by Channel enruta dinámicamente la tarea basándose en el valor del campo channel (email, slack o telegram).


8. Notificación y Entrega: El nodo de comunicación de n8n apropiado (Send Email Reminder, Send Slack Reminder o Send Telegram Reminder) entrega el mensaje de notificación personalizado.


9. Finalización: Finalmente, el nodo de n8n Update Task Status actualiza la tarea en PostgreSQL a 'sent' (enviada), evitando notificaciones duplicadas en ejecuciones futuras de este potente flujo de trabajo de n8n.

Para implementar este completo flujo de trabajo de n8n, sigue estos pasos:

1. Importar el JSON: Copia el JSON del flujo de trabajo de n8n proporcionado y pégalo en tu instancia de n8n usando el menú 'New' > 'Import from JSON'.


2. Configuración de PostgreSQL: Configura las credenciales de PostgreSQL utilizadas por los nodos de n8n Save Task to Database, Fetch Due Tasks y Update Task Status. Asegúrate de que tu base de datos contenga la tabla tasks con el esquema proporcionado en la nota adhesiva (sticky note).


3. Credenciales de Comunicación: Configura las credenciales para los nodos de n8n de entrega de recordatorios:

1. Activar Webhook: Copia la URL del webhook del disparador de n8n Webhook - Receive Task e intégrala en tu sistema de creación de tareas.


2. Activación: Asegúrate de que el flujo de trabajo de n8n esté marcado como 'Active' (Activo) para que el disparador programado comience a ejecutarse.

Este flujo de trabajo de n8n utiliza varios nodos críticos de n8n para lograr una funcionalidad robusta:

Webhook - Receive Task (Disparador de n8n): El punto de entrada principal. Escucha en una ruta específica (task-YOUROPENAIKEYHERE-webhook) para recibir solicitudes de creación de nuevas tareas.
Nodo Postgres (Save Task to Database): Almacena los datos de la tarea validados. Las configuraciones clave incluyen establecer la operación en 'Insert' y especificar la tabla de destino (implícitamente la tabla tasks).
Schedule Trigger - Every 5 Minutes (Disparador de n8n): Inicia periódicamente el proceso de comprobación de recordatorios usando la expresión cron /5 .
Nodo Postgres (Fetch Due Tasks): Ejecuta una consulta SQL personalizada (SELECT FROM tasks WHERE status = 'pending' AND remindertime <= NOW() + INTERVAL '5 minutes' AND remindertime > NOW()) para recuperar los registros relevantes.
Nodo If (Validate Input & Check Tasks Exist): Esencial para el control del flujo. El nodo de validación comprueba si las entradas clave no están vacías. La comprobación de existencia verifica si la base de datos devolvió algún elemento.
Nodo Switch (Route by Channel): Determina la ruta de entrega del recordatorio basándose en el campo channel de la tarea, conectando el flujo de n8n al Correo electrónico (Salida 0), Slack (Salida 1) o Telegram (Salida 2).
Nodo Email Send (Send Email Reminder): Configurado para enviar una línea de asunto personalizada (⏰ Task Reminder: {{ $json.taskname }}) y contenido del cuerpo al userid.
Nodo Slack (Send Slack Reminder): Envía un mensaje formateado en markdown, dirigiendo dinámicamente al usuario a través del userid recuperado del elemento de la base de datos.
Nodo Telegram (Send Telegram Reminder): Envía un mensaje usando formato Markdown a la chatId de destino ({{ $json.userid }}).
Nodo Postgres (Update Task Status): Ejecuta una consulta UPDATE para establecer status = 'sent' y sentat = NOW(), completando el ciclo para esta potente implementación de nodo n8n.