Semantic Kernel Agent Orchestration编排

一、多代理编排核心价值

Semantic Kernel的Agent Orchestration框架解决了传统单代理系统的局限性:

// 统一调用接口示例(适用于所有模式) InProcessRuntime runtime = new();   await runtime.StartAsync();  // 任意编排模式通用执行流程 OrchestrationResult<string> result = await orchestration.InvokeAsync(task, runtime);   string output = await result.GetValueAsync();  

通过协调具有​​不同专业技能​​的代理(如物理专家、化学专家),构建出能处理复杂工作流的协作系统。​​实验性提示​​:当前功能仍处实验阶段,API可能变更。

二、五种编排模式详解

1. 并发编排 (Concurrent)

​原理​​:向所有代理广播任务,独立收集结果
​适用场景​​:并行分析、多方案决策

// 定义不同领域的专家代理 ChatCompletionAgent physicist = new() {       Name = "物理专家",       Instructions = "你是一名物理学专家,从物理角度回答问题",       Kernel = kernel   };  ChatCompletionAgent chemist = new() {       Name = "化学专家",       Instructions = "你是一名化学专家,从化学角度分析问题",       Kernel = kernel   };  // 创建并发编排 ConcurrentOrchestration orchestration = new(physicist, chemist);    // 执行任务(获取温度定义的多元视角) var result = await orchestration.InvokeAsync("温度是什么?", runtime);   string[] outputs = await result.GetValueAsync();    /* 输出示例: 物理专家:温度是衡量粒子平均动能的物理量... 化学专家:温度反映了分子热运动的剧烈程度... */
2. 顺序编排 (Sequential)

​原理​​:按预设顺序传递处理结果,形成流水线
​适用场景​​:多阶段文档处理、供应链管理

// 创建营销处理流水线 ChatCompletionAgent analyst = new() {       Name = "市场分析师",       Instructions = "你是一名市场分析师,从产品描述中提取:n-核心功能n-目标用户n-独特卖点"   };  ChatCompletionAgent writer = new() {       Name = "文案撰写人",       Instructions = "根据分析结果撰写150字营销文案,只需输出文案正文"   };  ChatCompletionAgent editor = new() {       Name = "内容编辑",       Instructions = "优化文案语法,提升表达清晰度,保持风格统一"   };  // 构建顺序链 SequentialOrchestration orchestration = new(analyst, writer, editor);    // 执行产品文案生成 var result = await orchestration.InvokeAsync(       "一款环保不锈钢水杯,可保持饮品低温24小时", runtime);    /* 输出示例: 市场分析师:核心功能:环保材料、24小时保冷... 文案撰写人:全新环保不锈钢水杯,让您的冷饮持续冰爽... 内容编辑:【最终文案】创新环保不锈钢水杯... */
3. 群聊编排 (Group Chat)

​原理​​:通过管理器协调多代理对话
​适用场景​​:头脑风暴、争议解决

// 构建创意团队 ChatCompletionAgent writer = new() {       Name = "文案专员",       Instructions = "你是有十年经验的文案专家,擅长简洁幽默的表达,每次仅提出一个方案"   };  ChatCompletionAgent director = new() {       Name = "艺术总监",       Instructions = "你是一位崇尚David Ogilvy的创意总监,负责审核文案质量"   };  // 创建轮询式群聊(5轮对话上限) GroupChatOrchestration orchestration = new(       new RoundRobinGroupChatManager { MaximumInvocationCount = 5 },       writer, director   );  // 发起创意任务 var result = await orchestration.InvokeAsync(       "为经济型电动SUV设计广告标语", runtime);    /* 输出示例: 文案专员:“电动驾趣,触手可及” 艺术总监:建议加入环保元素... 文案专员:“绿色动力,轻松驰骋” */
4. 移交编排 (Handoff)

​原理​​:根据上下文动态转移控制权
​适用场景​​:多级客服系统、专家转接

// 构建客服代理链 OrchestrationHandoffs handoffs = OrchestrationHandoffs       .StartWith(triageAgent)       .Add(triageAgent, statusAgent, returnAgent, refundAgent)       .Add(statusAgent, triageAgent, "遇到非订单问题转接")       .Add(returnAgent, triageAgent, "遇到非退货问题转接");  // 模拟用户咨询队列 Queue<string> queries = new(new[] {       "我想查询订单状态", "订单号123", "需要退货", "订单号456", "商品破损"   });  // 创建移交编排(支持人工介入) HandoffOrchestration orchestration = new(handoffs) {       InteractiveCallback = () => ValueTask.FromResult(           new ChatMessageContent(AuthorRole.User, queries.Dequeue()))   };  // 处理用户请求 var result = await orchestration.InvokeAsync("我需要订单帮助", runtime);    /* 输出示例: 工单代理:请问您需要什么帮助?  订单代理:请提供订单号 退货代理:请描述退货原因... */
5. Magentic编排

​原理​​:管理器动态协调代理分工
​适用场景​​:研究分析、跨领域协作

// 创建研究+执行代理 ChatCompletionAgent researcher = new() {       Name = "研究专员",       Instructions = "你负责收集信息,不执行计算或量化分析",       Kernel = researchKernel // 使用gpt-4o-search-preview模型   };  AzureAIAgent coder = new() {       Name = "代码专员",       Instructions = "你使用代码处理数据,需提供详细分析过程",       Tools = { new CodeInterpreterToolDefinition() }  // 代码解释器   };  // 配置Magentic管理器 StandardMagenticManager manager = new(...) {       MaximumInvocationCount = 5  // 最大调用次数   };  // 构建复杂任务协作 MagenticOrchestration orchestration = new(manager, researcher, coder);    // 执行综合研究任务 var result = await orchestration.InvokeAsync(@"   比较ResNet-50、BERT-base和GPT-2在Azure Standard_NC6s_v3 VM上训练24小时的   能耗与CO2排放量,按图像分类/文本分类/文本生成任务给出建议", runtime);    /* 输出示例: 研究专员:根据论文A,ResNet-50训练能耗约45kWh... 代码专员:排放量计算代码:     emissions = energy * 0.387 // 微软区域排放因子 表格结果: | 模型       | 任务类型       | 能耗(kWh) | CO2(kg) | |----------|--------------|----------|---------| | ResNet-50| 图像分类      | 42       | 16.25   |  */

三、开发准备

  1. 安装必要包:
dotnet add package Microsoft.SemanticKernel.Agents.Orchestration --prerelease dotnet add package Microsoft.SemanticKernel.Agents.Runtime.InProcess --prerelease
  1. 统一架构优势:
// 所有模式共享相同调用接口 await orchestration.InvokeAsync(task, runtime);   await result.GetValueAsync();   await runtime.RunUntilIdleAsync(); 

​实验性声明​​:本文所述功能仍处开发阶段,API可能变更,生产环境慎用。完整示例代码详见官方GitHub仓库

 

发表评论

评论已关闭。

相关文章