n8n 工作流自动化：支持重试、日志记录与人工审核队列

目的

设计并输出具备健壮触发机制、幂等性、错误处理、日志记录、重试逻辑以及人工参与（human-in-the-loop）审核队列的 n8n 工作流 JSON。

适用场景

• 触发器相关需求：
  • 构建一个每周一运行并发送合规性摘要邮件的 n8n 工作流。
  • 为该工作流添加错误处理与重试机制，并配置失败项的人工审核队列。
  • 创建一个 Webhook 工作流，记录每次执行日志，并向追踪表写入状态行。
  • 使该 n8n 工作流具备幂等性，避免重复执行时产生重复记录。
  • 为该工作流注入审计日志能力，并加入人工审批步骤。
• 不适用场景：
  • 仅需纯代码自动化而无需 n8n（应使用脚本/CI 类技能）。
  • 需要绕过安全控制或隐藏审计痕迹。
  • 需要采购或推荐禁用物品/服务。

输入要求

• 必需输入：
  • 工作流意图：触发类型 + 调度计划/时区 + 成功判定标准。
  • 目标系统：结果写入位置（邮件/Drive/Sheet/DB）及所需字段。
• 可选输入：
  • 待修改的现有 n8n 工作流 JSON。
  • 示例请求载荷（payload）或样例记录。
  • 去重键（dedup key）定义（即用于唯一标识一条记录的字段组合）。
• 示例：
  • Cron：每周一 08:00（Europe/London）；发送摘要邮件 + 上传至 Drive
  • Webhook：接收 JSON 数据；按规则路由至不同文件夹

输出内容

• 默认输出（只读）：工作流设计规范（含节点定义、数据契约、失败模式分析）。
• 如明确要求：输出 workflow.json（可直接导入 n8n 的 JSON 文件） + runbook.md（基于模板生成）。 成功标志 = 工作流具备幂等性、每次执行均记录日志、重试行为安全可控、且所有失败项均被路由至审核队列。

工作流程

1. 明确触发机制：
   • Cron / Webhook / 手动触发；调度时间/时区；并发执行预期。
2. 定义数据契约：
   • 输入 Schema、必填字段、校验规则。
3. 设计幂等性机制：
   • 选定去重键（dedup key）及其存储位置（DB / Sheet），防止重试时生成重复记录。
4. 增强可观测性：
   • 生成 run_id，记录起止时间，持久化状态行与错误详情。
5. 实现错误处理：
   • 为各节点配置错误分支路径，启用带退避策略（backoff）的重试，并在最终失败时发出通知。
6. 添加人工审核队列（HITL）：
   • 将失败项写入队列（Sheet / DB），并强制要求人工审批后方可重新处理。
7. “零静默失败”防护门限：
   • 若统计数量或阈值未达标，则中止工作流并告警。
8. 输出阶段：
   • 若用户明确要求 JSON 输出：生成可导入 n8n 的工作流 JSON + 对应 runbook。
9. 以下情况需立即暂停并询问用户：
   • 目标系统信息未知；
   • 未提供去重键；
   • 凭证策略（如环境变量引用方式）未明确；
   • 工作流需调用尚未获批的特权访问接口。

输出格式

若输出 n8n 工作流 JSON，须严格遵循如下格式：

{
  "name": "",
  "nodes": [ { "name": "Trigger", "type": "n8n-nodes-base.cron", "parameters": {}, "position": [0,0] } ],
  "connections": {},
  "settings": {},
  "active": false
}

同时基于 assets/runbook-template.md 模板生成 runbook.md。

安全性与边界情况处理

• 默认为只读模式；仅在用户明确请求时才输出工作流 JSON。
• JSON 中不得包含任何密钥（secrets）；仅通过环境变量名或凭证名称进行引用。
• 必须集成审计日志与失败通知机制；禁止生成可能静默丢弃数据的工作流。
• 遵循最小权限原则：仅调用必要 API，尽可能缩小权限范围（scopes）。

示例

• 输入：“每周一 Cron 触发，发送合规性摘要邮件，对失败项启用重试。”
  输出：节点拓扑图 + 含 Cron → Fetch → Aggregate → Email 的 workflow.json，并配置错误分支通向审核队列。

• 输入：“接收 Webhook 请求，记录每次执行日志，并写入状态行。”
  输出：Webhook → Validate → Process → Append status row；出错时 → 记录日志 + 发送通知 + 写入审核队列。