Conductor 企业级事件驱动 Agentic 工作流引擎

这是什么？适合谁？

Conductor（conductor-oss/conductor）是 Netflix 开源、现为 Conductor OSS 社区维护的企业级事件驱动工作流引擎：把业务流程建模为可恢复（durable）、长期运行的执行图，任何一步失败都可重试、可回放、可审计——worker 崩了重新拉起，工作流从断点继续。2026 年起原生支持 AI Agent 任务节点（LLM 推理、MCP 工具发现、A2A 协议），成为「编排 AI Agent + 传统服务」的混合工作流底座。Netflix、Tesla、Disney 等公司的生产实践总结了它十年的演进。Apache-2.0，Java + Spring Boot（含 TypeScript/JavaScript UI），2026-09-23 核验：GitHub 32.2k★ / 1,013 fork，6,061 commits，最近提交 1 天前。

适合人群：

• 平台/基础设施团队：需要 durable 执行、 saga 模式、长事务编排的后端
• AI 工程团队：要把 LLM Agent 调用、人工审批、HTTP/事件任务编进同一张可恢复的流程图
• 从 Netflix/Orkes 生态迁移的企业：Java/Spring 技术栈契合

不适合谁：轻量级个人自动化（n8n/Zapier 更合适）；无 JVM 运维经验的纯前端团队。

准备工作

• 运行环境：JDK 21+（启动脚本会校验版本）；Docker 一条命令起服务
• 账号要求：无（OSS 版自托管；Orkes 云版另计）
• 持久化：Redis（最简）或 PostgreSQL/MySQL；索引可选 OpenSearch 2.x/3.x、Elasticsearch 7/8
• 时间预算：Docker 起服务 5 分钟；写第一个工作流 30 分钟
• 前置知识：JSON 工作流定义语法（或 Java/Python/Go/C#/JS SDK 任一）；了解幂等 worker 概念
• 替代方案：Temporal（代码优先 durable 执行）、Airflow（数据管道调度）、n8n（轻量可视化自动化）

核心流程（5 步跑通第一个工作流）

第一步：起服务

docker run -p 5000:5000 -p 8080:8080 conductoross/conductor:next
# 或用官方 conductor-server 启动脚本（JDK 21+）

第二步：打开 UI

浏览器访问 http://localhost:5000——可视化界面里可以画流程图、看执行历史、重试失败任务。

第三步：定义工作流（CLI）

conductor workflow create --file my_workflow.json

一个最小工作流 JSON 包含 name、tasks 数组；每个 task 是一个类型（HTTP、SUB_WORKFLOW、DO_WHILE、Agent 任务等）加输入输出模板。

第四步：跑一次执行

conductor execution start --workflow my_workflow

在 UI 里观察执行图逐步点亮；kill 掉 worker 再重启，验证断点恢复。

第五步：接自定义 worker（任选语言）

# pip install conductor-python
from conductor.client.worker import Worker
import time

class MyWorker(Worker):
    def execute(self, task):
        return {"output": {"result": "done"}}

# 注册到 server，轮询领取任务

预期产出：一个可在 UI 查看、可重试、可版本化、跨重启不丢状态的工作流执行。

Agentic 场景：官方文档「Build Your First AI Agent」给出 autonomous agent 范式——discover tools via MCP → reason with LLM → call tool → repeat，全部步骤 durable 持久化；还有「governed adaptive graph」（计划 → 校验批准能力 → 有限扇出/人工审批 → 评估 → 继续）的生产模式。

常见踩坑

1. worker 不幂等导致重放出错：durable 执行的前提是 task 可安全重试；副作用（扣款、发邮件）要自己做幂等键。
2. 索引后端选错版本：generic opensearch 索引类型已被改为弃用 stub，启动直接报错提示——要按 opensearch2 / opensearch3 明确选版本（ES6 同样已弃用转档）。
3. server-lite 已删除：网上旧教程引用 server-lite 模块会失败；canonical 分发是 server + ui-next。
4. JDK 版本解析坑：老版本启动脚本在 Windows 下 JAVA_MAJOR 解析有 bug（#754 已修），报奇怪版本错误先升级脚本/版本。
5. 600MB JAR 落在当前目录：官方启动脚本曾默认把 JAR 下到工作目录（#990 已修为 ~/.conductor-cli），旧脚本用户注意磁盘。
6. Redis 锁的 sentinel 配置：多 sentinel 地址要用分号分隔（redis-lock #951），逗号只用于 cluster 模式。

常见问题 FAQ

Q1：与 Temporal 怎么选？

A：Temporal 代码优先（workflow 即代码，框架强制确定性重放）；Conductor 声明式 JSON + UI 优先，引擎侧保证确定性而代码不必——运营团队看图改流程更友好，开发者取舍点在「声明式 vs 代码式」。

Q2：支持哪些语言写 worker？

A：Java/Python/JavaScript/Go/C# 均有官方 SDK（Ruby 孵育中）；worker 就是普通代码，任何能发 HTTP/gRPC 的语言都能接。

Q3：AI Agent 能力是噱头吗？

A：2026-02 起 grpc-server 合入 Agentic flows（#745），后续 A2A/AgentSpan 增强（#1356）、agent task UI（es7 #c85fa0f）持续迭代；其价值在「Agent 步骤获得与普通任务同等的 durable/审计/重试保障」，而非替代 Agent 框架本身。

Q4：能扛多大规模？

A：Netflix/Tesla/Disney 生产级验证（官方口径）；具体吞吐取决于持久化与索引后端选型，本文未做基准实测。

Q5：商业版和 OSS 什么关系？

A：Orkes（创始团队公司）提供云托管与企业版；OSS 版功能完整可自托管，Apache-2.0。

权限、安全、成本与限制

• 许可：Apache-2.0。
• 安全：自托管注意 5000/8080 端口不要裸露公网；依赖近年有多轮 CVE 修复记录（amqp-client、httpcore5 等，2026-09 仍在跟进），保持升级习惯。
• 成本：软件免费；成本在 JVM 服务器 + 持久化/索引后端（Redis/Postgres/OpenSearch）的运维。
• 限制：Java 技术栈为主；UI 定制与源码贡献需 Gradle 工程经验；本文基于官方 README 与仓库页撰写，未做大规模部署实测。

小技巧

1. 先用 UI 画草稿再导出 JSON 进版本库——「图即代码」两全。
2. conductor CLI 的每条命令都有等价的 HTTP 接口，CI 里用接口、本地调试用 CLI。
3. 长流程务必配 SUB_WORKFLOW 拆分层级，顶层图保持可读。
4. AI Agent 节点外包一层「人工审批」task，是 governed adaptive graph 的核心生产模式。
5. 官方仓库带 mkdocs 文档站源码（docs.conductor-oss.org），选型对比时直接看 Quickstart 的 polyglot worker 示例。

进阶学习方向

• Durable Execution 深入：官方文档 Durable Execution 章节 + saga 模式，理解「引擎确定性 vs 代码确定性」的设计取舍。
• Agentic 工作流：devguide/ai/first-ai-agent 与 dynamic-workflows 两篇是 Agent 编排的官方范式。
• 持久化矩阵：Redis（含 sentinel/cluster 细节）、Postgres、OpenSearch 2/3、ES7/8 各模块的选型与迁移（os-persistence 的弃用 stub 有完整迁移指引）。
• 生态 SDK：六个语言 SDK 仓库独立演进，深度集成时以各 SDK 仓库 README 为准。

参考链接

• 官方仓库
• 官网
• 官方文档
• Quickstart