Sistema de Lembretes de Tarefas Multicanal Controlado por Base de Dados - Fluxo de trabalho n8n

Administradores de sistemas e programadores que criam microsserviços de notificação.
Equipas que necessitam de agendamento de lembretes centralizado e configurável.
Utilizadores à procura de modelos n8n robustos e complexos para comunicação multicanal.
Qualquer pessoa que necessite de uma solução de automação resiliente, suportada por base de dados, utilizando o n8n.

Esta automação robusta resolve o desafio de criar um sistema de notificação de tarefas multicanal e fiável. Ao utilizar um fluxo de trabalho n8n, as tarefas são ingeridas através de um webhook dedicado e armazenadas de forma segura numa base de dados PostgreSQL. Uma parte crucial deste sistema é o gatilho (trigger) n8n agendado que verifica periodicamente as tarefas pendentes. A principal proposta de valor reside na sua capacidade de encaminhamento dinâmico, permitindo ao utilizador especificar o seu canal de comunicação preferido—Email, Slack ou Telegram—no momento da criação da tarefa. Esta arquitetura de fluxo de trabalho n8n avançada garante que os lembretes essenciais são entregues de forma fiável onde é mais provável que sejam vistos, tornando-o uma adição de grande valor a qualquer coleção de automação n8n. Este modelo demonstra as melhores práticas para utilizar o nó PostgreSQL do n8n para gestão de dados e controlo de fluxo dentro de um fluxo de trabalho n8n.

O fluxo de trabalho n8n está estruturado em dois componentes principais: Ingestão de Tarefas e Distribuição de Lembretes.

1. Ingestão de Tarefas (Gatilho Webhook): O processo começa quando uma aplicação externa aciona o gatilho Webhook - Receive Task do n8n, submetendo um payload JSON contendo os detalhes da tarefa.


2. Validação: O nó Validate Input do n8n impõe restrições, garantindo que userId, taskName e reminderTime são fornecidos. A falha aqui resulta numa Error Response imediata.


3. Persistência: As tarefas válidas avançam para o nó Save Task to Database do n8n, onde são armazenadas no PostgreSQL com o estado 'pending' (pendente). Uma operação bem-sucedida envia uma Success Response positiva.


4. Distribuição de Lembretes (Gatilho Agendado): A segunda metade deste fluxo de trabalho n8n é iniciada pelo gatilho Schedule Trigger - Every 5 Minutes do n8n, que é executado num agendamento cron (/5 *).


5. Consulta à Base de Dados: O nó Fetch Due Tasks do n8n consulta o PostgreSQL em busca de tarefas pendentes onde o reminder_time se aproxima ou já passou.


6. Controlo de Fluxo: O nó Check Tasks Exist do n8n garante que o fluxo só continua se foram recuperados registos. O fluxo divide então os registos usando o nó Split Into Items do n8n para processar cada tarefa de forma independente.


7. Encaminhamento por Canal: O nó Route by Channel do n8n encaminha dinamicamente a tarefa com base no valor do campo channel (email, slack ou telegram).


8. Notificação e Entrega: O nó de comunicação n8n apropriado (Send Email Reminder, Send Slack Reminder ou Send Telegram Reminder) entrega a mensagem de notificação personalizada.


9. Conclusão: Finalmente, o nó Update Task Status do n8n atualiza a tarefa no PostgreSQL para 'sent' (enviada), prevenindo notificações duplicadas em execuções futuras deste poderoso fluxo de trabalho n8n.

Para implementar este fluxo de trabalho n8n abrangente, siga estes passos:

1. Importar o JSON: Copie o JSON do fluxo de trabalho n8n fornecido e cole-o na sua instância do n8n usando o menu 'New' (Novo) > 'Import from JSON' (Importar de JSON).


2. Configuração do PostgreSQL: Configure as credenciais do PostgreSQL usadas pelos nós Save Task to Database, Fetch Due Tasks e Update Task Status do n8n. Certifique-se de que a sua base de dados contém a tabela tasks com o esquema fornecido na nota adesiva.


3. Credenciais de Comunicação: Configure as credenciais para os nós n8n de entrega de lembretes:

1. Ativar Webhook: Copie o URL do webhook do gatilho Webhook - Receive Task do n8n e integre-o no seu sistema de criação de tarefas.


2. Ativação: Garanta que o fluxo de trabalho n8n está marcado como 'Active' (Ativo) para que o gatilho agendado comece a ser executado.

Este fluxo de trabalho n8n utiliza vários nós críticos do n8n para alcançar uma funcionalidade robusta:

Webhook - Receive Task (gatilho n8n): O ponto de entrada principal. Escuta num caminho específico (task-YOUROPENAIKEYHERE-webhook) para receber pedidos de criação de novas tarefas.
Nó Postgres (Save Task to Database): Armazena os dados da tarefa validados. As configurações chave incluem definir a operação como 'Insert' (Inserir) e especificar a tabela de destino (tabela tasks implícita).
Schedule Trigger - Every 5 Minutes (gatilho n8n): Inicia periodicamente o processo de verificação de lembretes usando a expressão cron /5 .
Nó Postgres (Fetch Due Tasks): Executa uma consulta SQL personalizada (SELECT FROM tasks WHERE status = 'pending' AND remindertime <= NOW() + INTERVAL '5 minutes' AND remindertime > NOW()) para recuperar os registos relevantes.
Nó If (Validate Input & Check Tasks Exist): Essencial para o controlo de fluxo. O nó de validação verifica se as entradas chave não estão vazias. A verificação de existência confirma se a base de dados retornou algum item.
Nó Switch (Route by Channel): Determina o caminho de entrega do lembrete com base no valor do campo channel, ligando o fluxo n8n ao Email (Output 0), Slack (Output 1) ou Telegram (Output 2).
Nó de Envio de Email (Send Email Reminder): Configurado para enviar uma linha de assunto personalizada (⏰ Task Reminder: {{ $json.taskname }}) e conteúdo do corpo para o userid.
Nó Slack (Send Slack Reminder): Envia uma mensagem formatada em markdown, endereçando dinamicamente o utilizador através do userid recuperado do item da base de dados.
Nó Telegram (Send Telegram Reminder): Envia uma mensagem usando formatação Markdown para o chatId de destino ({{ $json.userid }}).
Nó Postgres (Update Task Status): Executa uma consulta UPDATE para definir status = 'sent' (enviado) e sentat = NOW(), completando o ciclo para esta poderosa implementação de nós n8n.