工作流编排

工作流编排完整指南

n8n 风格节点画布,可视化编排复杂 AI 流程。触发器 + 条件分支 + 循环 + 并行 + 子流程,无需写代码也能搭出企业级 AI Pipeline。

什么是工作流?

工作流(Workflow)是把多个 AI 能力(对话 / 检索 / 工具调用 / 模型调用) 按特定逻辑串联起来,完成单次对话无法完成的复杂任务。

适用场景:

多步骤任务:客服分流 → 工单创建 → 知识库检索 → 回复 → 满意度回访
定时任务:每天 9 点抓取行业新闻 → AI 摘要 → 推送企业微信
事件驱动:GitHub PR 创建 → 代码审查 Agent → 评论结果 → 通知 Slack
批处理:批量翻译 100 篇文章 → 校对 → 生成摘要 → 归档
人工协同:AI 起草 → 等待人工审核 → 修改 → 发布

节点类型

触发器(Trigger)

Manual:手动点击"运行"触发
Schedule:Cron 定时(如每天 9 点)
Webhook:HTTP POST 触发(外部系统调用)
Message:IM 消息触发(飞书/钉钉/Slack)
File Watch:文件变更触发(S3/OSS/本地)

AI 节点

Chat:LLM 对话(单轮 / 多轮)
RAG:知识库检索 + 生成
Agent:调用已有 Agent
Embedding:向量化
Vision:图像理解
TTS / STT:语音合成 / 识别

工具节点

HTTP Request:调用任意 API
MCP Tool:调用 MCP Server 工具
Code:执行 JS / Python 代码
Database:SQL 查询
File:读写文件(S3/OSS/本地)

控制流节点

If:条件分支(if / else if / else)
Switch:多分支选择
Loop:循环(foreach / while)
Parallel:并行执行多分支
Wait:等待(定时 / 事件 / 人工)
Sub-workflow:调用子工作流

创建第一个工作流

示例:每日行业新闻 AI 摘要推送

┌─────────────┐    ┌──────────────┐    ┌──────────────┐    ┌──────────────┐
│ Schedule    │ →  │ HTTP        │ →  │ AI 摘要     │ →  │ 推送        │
│ 每天 9:00   │    │ 抓取新闻 API │    │ GPT-4o 总结 │    │ 飞书/微信    │
└─────────────┘    └──────────────┘    └──────────────┘    └──────────────┘
                          ↓
                    ┌──────────────┐
                    │ If          │
                    │ 新闻 > 10 条 │ → 是 → 跑批
                    │              │ → 否 → 跳过
                    └──────────────┘

访问工作流页面,点击"新建工作流"
拖入 Schedule 节点,设置 Cron: 0 9 * * *
拖入 HTTP Request 节点,配置新闻 API URL
拖入 If 节点,条件:data.length > 10
拖入 AI 节点,选模型 GPT-4o,Prompt: "总结以下新闻为 3 条要点"
拖入 HTTP Request 节点,POST 到飞书 Webhook
连接节点,点击"测试运行"验证
保存 + 启用

高级特性

并行执行

多个独立分支同时执行,等所有分支完成后再汇聚 — 显著降低延迟。

Parallel:
  ├─ AI 翻译(英文)  ─┐
  ├─ AI 翻译(日文)  ─┤→ 汇总 → 发布
  ├─ AI 翻译(韩文)  ─┤
  └─ AI 翻译(法文)  ─┘
# 4 个翻译并行,总耗时 = max(单次)而非 sum

循环 + 批处理

Foreach 循环处理数组,自动限流避免触发 API Rate Limit。

Loop (foreach articles):
  ├─ AI 摘要
  ├─ AI 分类
  └─ 写入数据库
# concurrency: 5  # 并发 5 个,避免限流

子工作流

把常用流程封装为子工作流,主工作流调用 — 复用 + 维护性强。

主工作流:
  ├─ 子工作流: "通用翻译"(输入文本,输出译文)
  ├─ 子工作流: "通用摘要"(输入文本,输出摘要)
  └─ 子工作流: "通用分类"(输入文本,输出标签)

# 修改"通用翻译"一处,所有引用它的主工作流自动生效

人工审批

AI 起草后暂停,等待人工审批通过后继续执行 — 关键场景必备。

Wait (human approval):
  - 通知: 飞书审批消息
  - 超时: 24h 未审批自动拒绝
  - 通过: 继续发布
  - 拒绝: 进入"拒绝"分支

监控与调试

实时执行日志:每个节点的输入 / 输出 / 耗时 / 状态实时显示
断点调试:在任意节点设置断点,单步执行查看中间结果
历史记录:每次执行完整快照,可回放复现问题
错误重试:节点失败自动重试 3 次(可配),仍失败则告警
性能分析:瓶颈节点自动标红,提示优化
告警:失败 / 超时 / 死循环自动通知 Admin

下一步

Agent 开发 →
工作流内嵌 Agent 节点 MCP 工具集成 →
工作流调用 MCP 工具 API 参考 →
通过 API 触发工作流

什么是工作流?

工作流(Workflow)是把多个 AI 能力(对话 / 检索 / 工具调用 / 模型调用) 按特定逻辑串联起来,完成单次对话无法完成的复杂任务。

适用场景:

多步骤任务:客服分流 → 工单创建 → 知识库检索 → 回复 → 满意度回访
定时任务:每天 9 点抓取行业新闻 → AI 摘要 → 推送企业微信
事件驱动:GitHub PR 创建 → 代码审查 Agent → 评论结果 → 通知 Slack
批处理:批量翻译 100 篇文章 → 校对 → 生成摘要 → 归档
人工协同:AI 起草 → 等待人工审核 → 修改 → 发布

节点类型

触发器(Trigger)

Manual:手动点击"运行"触发
Schedule:Cron 定时(如每天 9 点)
Webhook:HTTP POST 触发(外部系统调用)
Message:IM 消息触发(飞书/钉钉/Slack)
File Watch:文件变更触发(S3/OSS/本地)

AI 节点

Chat:LLM 对话(单轮 / 多轮)
RAG:知识库检索 + 生成
Agent:调用已有 Agent
Embedding:向量化
Vision:图像理解
TTS / STT:语音合成 / 识别

工具节点

HTTP Request:调用任意 API
MCP Tool:调用 MCP Server 工具
Code:执行 JS / Python 代码
Database:SQL 查询
File:读写文件(S3/OSS/本地)

控制流节点

If:条件分支(if / else if / else)
Switch:多分支选择
Loop:循环(foreach / while)
Parallel:并行执行多分支
Wait:等待(定时 / 事件 / 人工)
Sub-workflow:调用子工作流

创建第一个工作流

示例:每日行业新闻 AI 摘要推送

┌─────────────┐    ┌──────────────┐    ┌──────────────┐    ┌──────────────┐
│ Schedule    │ →  │ HTTP        │ →  │ AI 摘要     │ →  │ 推送        │
│ 每天 9:00   │    │ 抓取新闻 API │    │ GPT-4o 总结 │    │ 飞书/微信    │
└─────────────┘    └──────────────┘    └──────────────┘    └──────────────┘
                          ↓
                    ┌──────────────┐
                    │ If          │
                    │ 新闻 > 10 条 │ → 是 → 跑批
                    │              │ → 否 → 跳过
                    └──────────────┘

访问工作流页面,点击"新建工作流"
拖入 Schedule 节点,设置 Cron: 0 9 * * *
拖入 HTTP Request 节点,配置新闻 API URL
拖入 If 节点,条件:data.length > 10
拖入 AI 节点,选模型 GPT-4o,Prompt: "总结以下新闻为 3 条要点"
拖入 HTTP Request 节点,POST 到飞书 Webhook
连接节点,点击"测试运行"验证
保存 + 启用

高级特性

并行执行

多个独立分支同时执行,等所有分支完成后再汇聚 — 显著降低延迟。

Parallel:
  ├─ AI 翻译(英文)  ─┐
  ├─ AI 翻译(日文)  ─┤→ 汇总 → 发布
  ├─ AI 翻译(韩文)  ─┤
  └─ AI 翻译(法文)  ─┘
# 4 个翻译并行,总耗时 = max(单次)而非 sum

循环 + 批处理

Foreach 循环处理数组,自动限流避免触发 API Rate Limit。

Loop (foreach articles):
  ├─ AI 摘要
  ├─ AI 分类
  └─ 写入数据库
# concurrency: 5  # 并发 5 个,避免限流

子工作流

把常用流程封装为子工作流,主工作流调用 — 复用 + 维护性强。

主工作流:
  ├─ 子工作流: "通用翻译"(输入文本,输出译文)
  ├─ 子工作流: "通用摘要"(输入文本,输出摘要)
  └─ 子工作流: "通用分类"(输入文本,输出标签)

# 修改"通用翻译"一处,所有引用它的主工作流自动生效

人工审批

AI 起草后暂停,等待人工审批通过后继续执行 — 关键场景必备。

Wait (human approval):
  - 通知: 飞书审批消息
  - 超时: 24h 未审批自动拒绝
  - 通过: 继续发布
  - 拒绝: 进入"拒绝"分支

监控与调试

实时执行日志:每个节点的输入 / 输出 / 耗时 / 状态实时显示
断点调试:在任意节点设置断点,单步执行查看中间结果
历史记录:每次执行完整快照,可回放复现问题
错误重试:节点失败自动重试 3 次(可配),仍失败则告警
性能分析:瓶颈节点自动标红,提示优化
告警:失败 / 超时 / 死循环自动通知 Admin

开发文档

开发文档

工作流编排完整指南

什么是工作流?

节点类型

创建第一个工作流

高级特性

并行执行

循环 + 批处理

子工作流

人工审批

监控与调试

下一步

工作流编排完整指南

什么是工作流?

节点类型

创建第一个工作流

高级特性

并行执行

循环 + 批处理

子工作流

人工审批

监控与调试

下一步