---

name: n8n-workflow-patterns description: "经过验证的 n8n 工作流架构模式。" risk: unknown source: community

n8n 工作流模式

经过验证的 n8n 工作流架构模式。

何时使用

• 你需要在构建 n8n 工作流之前选择一种架构模式。
• 任务涉及 webhook 处理、API 集成、定时任务、数据库同步或 AI 代理工作流设计。
• 你需要高层次的工作流结构，而非逐节点的故障排除。

---

5 种核心模式

基于实际工作流使用分析：

1. Webhook 处理（最常见）

   • 接收 HTTP 请求 → 处理 → 输出
   • 模式：Webhook → 验证 → 转换 → 响应/通知

2. [HTTP API 集成]

   • 从 REST API 获取数据 → 转换 → 存储/使用
   • 模式：触发器 → HTTP 请求 → 转换 → 操作 → 错误处理

3. 数据库操作

   • 读取/写入/同步数据库数据
   • 模式：定时 → 查询 → 转换 → 写入 → 验证

4. AI 代理工作流

   • 带工具和记忆的 AI 代理
   • 模式：触发器 → AI 代理（模型 + 工具 + 记忆）→ 输出

5. 定时任务

   • 周期性自动化工作流
   • 模式：定时 → 获取 → 处理 → 交付 → 日志

---

模式选择指南

何时使用每种模式：

Webhook 处理 - 适用于：

• 从外部系统接收数据
• 构建集成（Slack 命令、表单提交、GitHub webhooks）
• 需要对事件即时响应
• 示例："接收 Stripe 支付 webhook → 更新数据库 → 发送确认"

HTTP API 集成 - 适用于：

• 从外部 API 获取数据
• 与第三方服务同步
• 构建数据管道
• 示例："获取 GitHub issues → 转换 → 创建 Jira 工单"

数据库操作 - 适用于：

• 数据库之间同步
• 按计划运行数据库查询
• ETL 工作流
• 示例："读取 Postgres 记录 → 转换 → 写入 MySQL"

AI 代理工作流 - 适用于：

• 构建对话式 AI
• 需要 AI 具有工具访问能力
• 多步推理任务
• 示例："与能搜索文档、查询数据库、发送邮件的 AI 对话"

定时任务 - 适用于：

• 周期性报告或摘要
• 定期数据获取
• 维护任务
• 示例："每日：获取分析数据 → 生成报告 → 邮件发送给团队"

---

常用工作流组件

所有模式共享以下构建块：

1. 触发器

• Webhook - HTTP 端点（即时）
• Schedule - 基于 Cron 的定时（周期性）
• Manual - 点击执行（测试）
• Polling - 检查变更（间隔）

2. 数据源

• HTTP Request - REST API
• Database 节点 - Postgres、MySQL、MongoDB
• Service 节点 - Slack、Google Sheets 等
• Code - 自定义 JavaScript/Python

3. 转换

• Set - 映射/转换字段
• Code - 复杂逻辑
• IF/Switch - 条件路由
• Merge - 合并数据流

4. 输出

• HTTP Request - 调用 API
• Database - 写入数据
• Communication - 邮件、Slack、Discord
• Storage - 文件、云存储

5. 错误处理

• Error Trigger - 捕获工作流错误
• IF - 检查错误条件
• Stop and Error - 显式失败
• Continue On Fail - 每节点设置

---

工作流创建清单

构建任何工作流时，请遵循此清单：

规划阶段

• [ ] 确定模式（webhook、API、数据库、AI、定时）
• [ ] 列出所需节点（使用 search_nodes）
• [ ] 理解数据流（输入 → 转换 → 输出）
• [ ] 规划错误处理策略

实施阶段

• [ ] 使用适当的触发器创建工作流
• [ ] 添加数据源节点
• [ ] 配置认证/凭证
• [ ] 添加转换节点（Set、Code、IF）
• [ ] 添加输出/操作节点
• [ ] 配置错误处理

验证阶段

• [ ] 验证每个节点配置（validate_node）
• [ ] 验证完整工作流（validate_workflow）
• [ ] 使用示例数据测试
• [ ] 处理边界情况（空数据、错误）

部署阶段

• [ ] 检查工作流设置（执行顺序、超时、错误处理）
• [ ] 使用 activateWorkflow 操作激活工作流
• [ ] 监控首次执行
• [ ] 记录工作流目的和数据流

---

数据流模式

线性流

Trigger → Transform → Action → End

适用于：具有单一路径的简单工作流

分支流

Trigger → IF → [True Path]
             └→ [False Path]

适用于：基于条件执行不同操作

并行处理

Trigger → [Branch 1] → Merge
       └→ [Branch 2] ↗

适用于：可同时运行的独立操作

循环模式

Trigger → Split in Batches → Process → Loop (until done)

适用于：分批处理大型数据集

错误处理模式

Main Flow → [Success Path]
         └→ [Error Trigger → Error Handler]

适用于