n8n 工作流自动化 - 重试、日志记录和审核队列

目的

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

使用场景

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

输入

• 必需：
  • 工作流意图：触发器类型 + 计划/时区 + 成功标准
  • 目标：结果写入位置（email/Drive/Sheet/DB）和必需字段
• 可选：
  • 要修改的现有 n8n 工作流 JSON
  • 示例负载 / 示例记录
  • 去重键定义（什么使记录唯一）
• 示例：
  • Cron：周一 08:00 Europe/London；发送摘要邮件 + Drive 上传
  • Webhook：接收 JSON；路由到文件夹

输出

• 默认（只读）：工作流设计规范（节点、数据契约、失败模式）
• 如果明确请求：workflow.json（n8n 可导入 JSON）+ runbook.md（来自模板） 成功 = 工作流具有幂等性、记录每次运行、安全重试，并将失败路由到审核队列

工作流程

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

输出格式

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

{
  "name": "<workflow 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 中包含密钥；仅引用环境变量/凭证名称
• 包含审计日志 + 失败通知；避免可能静默丢失数据的工作流
• 优先最小权限：仅调用所需的 API 并最小化范围

示例

• 输入："每周一 cron，发送合规摘要，重试失败。" 输出：节点图 + workflow.json（包含 Cron → Fetch → Aggregate → Email），加上错误分支到审核队列

• 输入："记录运行并写入状态行的 Webhook。" 输出：Webhook → Validate → Process → Append status row；错误时 → log + notify + queue