多渠道数据库驱动的任务提醒系统 - n8n 工作流

构建通知微服务的系统管理员和开发者。
需要集中式、可配置提醒调度的团队。
正在寻找用于多渠道通信的健壮、复杂的 n8n 模板的用户。
任何需要使用 n8n 实现基于数据库支持的、高可用自动化解决方案的人员。

这个强大的自动化方案解决了构建可靠的多渠道任务通知系统的难题。通过利用 n8n 工作流，任务通过专用的 Webhook 接入并安全地存储在 PostgreSQL 数据库中。该系统的关键部分是定时的 n8n 触发器，它会定期检查待处理的任务。其核心价值在于动态路由能力，允许用户在创建任务时指定首选的通信渠道——邮件、Slack 还是 Telegram。这种先进的 n8n 工作流架构确保了核心任务提醒能够可靠地送达最可能被注意到的地方，使其成为任何 n8n 自动化集合中的宝贵补充。此模板展示了在 n8n 工作流中使用 PostgreSQL n8n 节点进行数据管理和流程控制的最佳实践。

n8n 工作流主要由两个部分构成：任务接入和提醒分发。

1. 任务接入 (Webhook 触发器): 流程始于外部应用调用 Webhook - Receive Task n8n 触发器，提交包含任务详情的 JSON 数据包（payload）。


2. 校验: Validate Input n8n 节点执行约束检查，确保提供了 userId、taskName 和 reminderTime。此处失败将立即返回 Error Response（错误响应）。


3. 持久化: 通过校验的任务将进入 Save Task to Database n8n 节点，以 'pending'（待处理）状态存储在 PostgreSQL 中。操作成功后会发送 Success Response（成功响应）。


4. 提醒分发 (定时触发器): n8n 工作流的后半部分由 Schedule Trigger - Every 5 Minutes n8n 触发器启动，它按照 /5 * 的 Cron 计划执行。


5. 数据库查询: Fetch Due Tasks n8n 节点查询 PostgreSQL，找出即将到达或已过期的待处理任务。


6. 流程控制: Check Tasks Exist n8n 节点确保只有在检索到记录时流程才会继续。然后流程使用 Split Into Items n8n 节点拆分记录，以便独立处理每个任务。


7. 渠道路由: Route by Channel n8n 节点根据任务的 channel 字段（email, slack, 或 telegram）的值动态路由任务。


8. 通知与发送: 相应的通信 n8n 节点（Send Email Reminder、Send Slack Reminder 或 Send Telegram Reminder）发送定制化的通知消息。


9. 完成: 最后，Update Task Status n8n 节点将 PostgreSQL 中的任务状态更新为 'sent'（已发送），从而完成这个强大的 n8n 工作流的闭环。

要部署这个完整的 n8n 工作流，请遵循以下步骤：

1. 导入 JSON: 复制提供的 n8n 工作流 JSON，并使用 n8n 实例中的“新建”菜单 > “从 JSON 导入”将其粘贴进去。


2. PostgreSQL 设置: 配置 Save Task to Database、Fetch Due Tasks 和 Update Task Status n8n 节点所使用的 PostgreSQL 凭据。确保您的数据库包含粘滞便笺中提供的 tasks 表结构。


3. 通信凭据配置: 为提醒分发的 n8n 节点设置凭据：

1. 激活 Webhook: 从 Webhook - Receive Task n8n 触发器复制 Webhook 地址，并将其集成到您的任务创建系统中。


2. 启用: 确保 n8n 工作流被标记为“激活”(Active)，以便定时触发器开始运行。

此 n8n 工作流使用多个关键的 n8n 节点来实现其强大的功能：

Webhook - Receive Task (n8n 触发器): 主要的入口点。它监听特定路径（task-YOUROPENAIKEYHERE-webhook）以接收新的任务创建请求。
Postgres 节点 (Save Task to Database): 存储已校验的任务数据。关键配置包括将操作设置为“Insert”（插入）并指定目标表（隐含为 tasks 表）。
Schedule Trigger - Every 5 Minutes (n8n 触发器): 使用 Cron 表达式 /5 定期启动提醒检查流程。
Postgres 节点 (Fetch Due Tasks): 执行自定义 SQL 查询（SELECT FROM tasks WHERE status = 'pending' AND remindertime <= NOW() + INTERVAL '5 minutes' AND remindertime > NOW()）以检索相关记录。
If 节点 (Validate Input & Check Tasks Exist): 对于流程控制至关重要。验证节点检查关键输入是否为空。存在性检查则验证数据库是否返回了任何数据项。
Switch 节点 (Route by Channel): 根据任务的 channel 字段确定提醒的发送路径，将 n8n 流程连接到邮件（输出 0）、Slack（输出 1）或 Telegram（输出 2）。
Email Send 节点 (Send Email Reminder): 配置为向 userid 发送个性化的主题行（⏰ Task Reminder: {{ $json.taskname }}）和正文内容。
Slack 节点 (Send Slack Reminder): 发送格式化的 Markdown 消息，通过从数据库项目中检索到的 userid 向用户动态发送消息。
Telegram 节点 (Send Telegram Reminder): 使用 Markdown 格式向目标 chatId（即 {{ $json.userid }}）发送消息。
Postgres 节点 (Update Task Status): 执行 UPDATE 查询，将 status 设置为 'sent' 并将 sentat 设置为 NOW()，从而完成这个强大的 n8n 节点实现的闭环。