SuperAPI AI 工具集

ai-agent-orchestrator

智能体与模型

查看项目

更新于 10-15 15:11

技能介绍

AI Agent Orchestrator 面向需要构建多智能体协作系统的开发者,目标是用多个专职 AI 智能体完成复杂任务的自动化。资料将其定位为「为复杂任务自动化构建协调的多智能体系统」。

【核心工作流】 资料给出的流程包括六步:1)定义智能体:创建专业化智能体;2)设计工作流:规划智能体协作方式;3)实现交接(handoffs):智能体之间的通信;4)添加共享记忆:持久化上下文;5)创建主管:编排执行;6)监控执行:跟踪智能体活动。

【主要能力】

  1. 智能体基础架构:提供 Agent 基类(agents/base.ts),基于 @langchain/openai 的 ChatOpenAI 与 @langchain/core/messages。AgentConfig 包含 name、role、systemPrompt、tools、model;AgentResponse 包含 content、toolCalls、nextAgent、completed。Agent 类维护 messageHistory,通过 buildSystemPrompt 注入 context,parseResponse 识别工具调用与完成标记,并提供 clearHistory。
  2. 专业化智能体(agents/specialists.ts):预置 ResearchAgent(研究专员,具备搜索与网页抓取工具,完成时输出 [TASK_COMPLETE],需要协助时输出 [HANDOFF:agent_name])、WriterAgent(内容写作者,输出 [TASK_COMPLETE])、ReviewerAgent(质量审核者,通过时输出 [APPROVED],需修改时输出 [REVISIONS_NEEDED])、PlannerAgent(任务规划者,输出结构化 JSON 计划,含 goal 与 steps,每步指定 agent 与 task)。
  3. 顺序编排器(orchestrator/sequential.ts):SequentialOrchestrator 支持 registerAgent 与 execute(workflow),按 WorkflowStep 列表依次执行,可通过 inputFrom 把上一步输出拼接到当前任务输入,结果按智能体名存入 results。示例工作流为「研究 2024 AI 趋势 → 写博客 → 审核」。
  4. 主管编排器(orchestrator/supervisor.ts):SupervisorOrchestrator 使用温度 0 的模型作为主管,维护 agents 注册表、sharedContext 与 maxIterations(默认 10)。execute 循环调用 supervise 决定下一步:返回 complete 为 true 时给出 finalResponse,否则选择 nextAgent 与 agentTask 执行,更新共享上下文与历史;若结果含 nextAgent 则据此更新 currentTask;超过最大迭代数抛出错误。supervise 用 JSON 结构输出 thought、complete、nextAgent、agentTask 或 finalResponse。
  5. 并行执行(orchestrator/parallel.ts):ParallelOrchestrator 提供 executeParallel,用 Promise.all 并发执行多个 {agentName, task};以及 fanOutFanIn,将同一任务分发给多个智能体(fan out),再把各结果拼接后交给聚合智能体综合(fan in)。
  6. 共享记忆(memory/shared.ts):SharedMemory 基于 ioredis,使用 agent:{sessionId}: 前缀,提供 set(支持 TTL)、get、append、getConversation、addMessage、getAgentOutputs、setAgentOutput、clear(按前缀批量删除)。
  7. 事件驱动通信(events/agent-events.ts):AgentEventBus 继承 EventEmitter 并为单例,提供 emitAgentMessage(定向消息)、emitAgentComplete、emitAgentError、onMessage、onAnyComplete。示例中写作者监听自身消息并执行任务后广播完成事件,编排器监听所有完成事件。
  8. 工作流定义(workflows/definition.ts):WorkflowDefinition 含 name、description、agents、steps、errorHandling(retry | fallback | abort)。示例 ContentCreationWorkflow 含 plan、research(parallel: true)、write(dependsOn: ['research'])、review(loop 条件 review.approved === false,最多 3 次,回退到 write)等步骤,错误处理为 retry。

【使用方式】 资料以 TypeScript 代码示例展示用法,例如注册 ResearchAgent、WriterAgent、ReviewerAgent 后调用 orchestrator.execute 依次执行三步任务。代码依赖 @langchain/openai、@langchain/core/messages、ioredis 等,需通过 process.env.REDIS_URL 配置 Redis 连接。资料未提供安装命令或具体部署步骤。

【最佳实践与输出清单】 最佳实践包括:单一职责(每个智能体一个清晰角色)、明确交接、共享上下文、迭代上限、错误处理、可观测性(记录所有智能体动作)、测试(单独与联合测试)、超时处理。输出清单要求系统包含:Agent 基类、专业化智能体、编排器、共享记忆、事件通信、工作流定义、错误处理与重试、迭代上限、日志与监控、智能体交接协议。

【适用场景】 适合需要进行多智能体任务分解与协作的开发场景,例如内容创作流水线(规划、研究、写作、审核)、需要并行收集多视角再聚合的任务、需要主管动态调度智能体的复杂流程。

【限制与缺失信息】 资料未提供安装命令、版本要求、定价与授权信息、支持平台说明,也未提供实测效果数据;代码示例基于 OpenAI 模型与 Redis,实际运行需自备相应密钥与基础设施。