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

目的

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

适用场景

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

输入要求

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

输出内容

• 默认输出（只读）：一份工作流设计说明文档（含节点拓扑、数据契约、故障模式分析）。
• 如明确请求：输出 workflow.json（可直接导入 n8n 的 JSON 文件） + runbook.md（基于模板生成）。 成功标准 = 工作流具备幂等性、每次运行均被记录、重试行为安全可控、所有失败任务均路由至审核队列。

工作流设计流程

1. 明确触发机制：
   • Cron / Webhook / 手动触发；调度时间与时区；预期并发数。
2. 定义数据契约：
   • 输入 Schema、必填字段、校验规则。
3. 设计幂等性保障：
   • 选定去重键（dedup key(s)）及其存储位置（数据库/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），仅允许引用环境变量名或凭证名称（credential names）。
• 必须包含审计日志与失败通知机制；禁止生成可能静默丢弃数据的工作流。
• 遵循最小权限原则：仅调用必需的 API，并尽可能缩减权限范围（scopes）。

示例

• 输入：“每周一 Cron 触发，发送合规性摘要邮件，失败时自动重试。”
  输出：节点关系图 + workflow.json（含 Cron → Fetch → Aggregate → Email 节点链路，以及指向审核队列的错误分支）。

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