具备重试、日志记录和审核队列功能的n8n工作流自动化

目的

设计并输出具备稳健触发器、幂等性、错误处理、日志记录、重试机制以及人工参与审核队列的n8n工作流JSON。

使用时机

• 触发器：
  • 构建一个每周一运行并通过电子邮件发送合规摘要的n8n工作流。
  • 为此工作流添加错误处理和重试机制，并为失败情况设置审核队列。
  • 创建一个记录每次运行并将状态行写入跟踪器的Webhook工作流。
  • 使此n8n流程具备幂等性，以便在重新运行时不会重复记录。
  • 为此工作流配备审计日志和人工审批步骤。
• 请勿在以下情况使用…
  • 您需要纯代码自动化而不使用n8n时（请使用脚本/CI技能）。
  • 您需要绕过安全控制或隐藏审计踪迹时。
  • 您需要购买或推荐违禁物品/服务时。

输入

• 必需：
  • 工作流意图：触发器类型 + 计划/时区 + 成功标准。
  • 目标：结果写入位置（电子邮件/云端硬盘/表格/数据库）及所需字段。
• 可选：
  • 用于修改的现有n8n工作流JSON。
  • 示例载荷 / 记录样本。
  • 去重键定义（决定记录唯一性的字段）。
• 示例：
  • 定时任务：周一 08:00 欧洲/伦敦时区；发送摘要邮件 + 云端硬盘上传
  • Webhook：接收JSON；路由到文件夹

输出

• 默认（只读）：工作流设计规范（节点、数据契约、故障模式）。
• 若明确请求：workflow.json（可导入n8n的JSON） +runbook.md（基于模板）。 成功标准 = 工作流具备幂等性、记录每次运行、安全重试，并将失败情况路由至审核队列。

工作流

1. 明确触发器：
   • 定时任务/Webhook/手动；计划/时区；并发预期。
2. 定义数据契约：
   • 输入模式、必需字段和验证规则。
3. 设计幂等性：
   • 选择去重键及其存储位置（数据库/表格），以防止重试时产生重复记录。
4. 添加可观测性：
   • 生成运行ID，记录开始/结束，存储状态行和错误详情。
5. 实施错误处理：
   • 每个节点的错误分支、带退避的重试以及最终失败通知。
6. 添加人在回路（HITL）审核队列：
   • 将失败项写入队列（表格/数据库）并需要批准才能重新处理。
7. “无静默失败”关卡：
   • 如果计数/阈值失败，则停止工作流并发出警报。
8. 输出：
   • 如果要求JSON：生成可导入的n8n工作流JSON + 操作手册。
9. 在以下情况下停止并询问用户：
   • 目标系统未知，
   • 不存在去重键，
   • 未指定凭据策略（环境变量），
   • 工作流需要尚未批准的权限访问。

输出格式

如果输出n8n工作流JSON，需符合：

{
  "name": "<工作流名称>",
  "nodes": [ { "name": "触发器", "type": "n8n-nodes-base.cron", "parameters": {}, "position": [0,0] } ],
  "connections": {},
  "settings": {},
  "active": false
}

同时输出runbook.md使用assets/runbook-template.md。

安全与边界情况

• 默认只读；仅在明确要求时发出工作流JSON。
• 不要在JSON中包含密钥；仅引用环境变量/凭据名称。
• 包含审计日志记录 + 失败通知；避免可能导致数据静默丢失的工作流。
• 优先最小权限：仅调用必需的API并最小化范围。

示例

• 输入：“每周一Cron任务，邮件发送合规摘要，重试失败项。”
  输出：节点映射 +workflow.json包含Cron → 获取 → 聚合 → 邮件，以及指向审核队列的错误分支。

• 输入：“记录运行并写入状态行的Webhook。”
  输出：Webhook → 验证 → 处理 → 追加状态行；错误时 → 记录 + 通知 + 加入队列。