快速集成A2A Agent

面我们提到可以将MCP服务也封装为一个ToolAIFunction让Agent调用这里A2A Agent也是一样的道理。这样做的好处是让MAF中的Agent像调用本地函数一样调用远程A2A Agent 或 MCP Server。下面的代码展示了在MAF中将A2A Card转换为Agent然后再将Agent转换为AIFunction...... var functionTools new ListAIFunction(); foreach (var endpoint in agentEndpoints) { var resolver new A2ACardResolver(new Uri(endpoint)); var card await resolver.GetAgentCardAsync(); var agent card.AsAIAgent(); // Convert A2A Agent to AIAgent instance functionTools.AddRange(AgentFunctionHelper.CreateFunctionTools(agent, card)); } ......下面是AgentFunctionHelper类的代码实现public class AgentFunctionHelper { public static IEnumerableAIFunction CreateFunctionTools(AIAgent a2aAgent, AgentCard agentCard) { foreach (var skill in agentCard.Skills) { AIFunctionFactoryOptions options new() { Name Sanitize(skill.Id), Description $$ { description: {{skill.Description}}, tags: [{{string.Join(, , skill.Tags ?? [])}}], examples: [{{string.Join(, , skill.Examples ?? [])}}], inputModes: [{{string.Join(, , skill.InputModes ?? [])}}], outputModes: [{{string.Join(, , skill.OutputModes ?? [])}}] } , }; yield return AIFunctionFactory.Create(RunAgentAsync, options); } async Taskstring RunAgentAsync(string input, CancellationToken cancellationToken) { var response await a2aAgent.RunAsync(input, cancellationToken: cancellationToken).ConfigureAwait(false); return response.Text; } } private static readonly Regex InvalidNameCharsRegex new Regex([^0-9A-Za-z], RegexOptions.Compiled); public staticstringSanitize(string name) { return InvalidNameCharsRegex.Replace(name, _); } }其中的CreateFunctionTools方法实现了将A2A Agent的所有公开技能转换为AIFunction工具。而Sanitize方法则实现了函数名称的规范化因为AIFunction的名称必须符合一定规范仅限字母、数字和下划线因此需要主动对技能名称进行规范化。3 完整集成示例这次我们还是使用上次文章中的案例即一个旅游助手它可以通过A2A协议调用多个Agent的技能。我们需要创建四个.NET项目其中1个.NET控制台项目主助手3个ASP.NET Web项目天气智能体、酒店智能体、路线智能体在VS中的项目结构如下本次案例我们希望实现主助手可以回答用户关于不同主题景点酒店天气的问题它可以根据问题自主选择需要调用一个或多个Agent去获取必要的信息后进行整合优化后再回复用户。3.1 天气Agent添加NuGet包后续A2A Agent项目都需要安装此包不再赘述A2A.AspNetCore创建一个 WeatherAgent类定义其能力 和 AgentCard这里我们需要公开一个AgentSkill即天气查询的能力public class WeatherAgent { public void Attach(ITaskManager taskManager) { taskManager.OnMessageReceived QueryWeatherAsync; taskManager.OnAgentCardQuery GetAgentCardAsync; } private TaskA2AResponse QueryWeatherAsync(MessageSendParams messageSendParams, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledA2AResponse(cancellationToken); } // Process the message var messageText messageSendParams.Message.Parts.OfTypeTextPart().First().Text; // Create and return an artifact var message new AgentMessage() { Role MessageRole.Agent, MessageId Guid.NewGuid().ToString(), ContextId messageSendParams.Message.ContextId, Parts [new TextPart() { Text $ ️ **天气查询结果** 查询时间{DateTime.Now:yyyy-MM-dd HH:mm} **北京天气** - 今日晴转多云气温 -2°C ~ 8°C - 明日多云气温 0°C ~ 10°C - 后日阴气温 2°C ~ 9°C **上海天气** - 今日多云气温 5°C ~ 12°C - 明日小雨气温 6°C ~ 10°C - 后日阴转晴气温 4°C ~ 11°C 穿衣建议北京较冷建议穿羽绒服上海温和建议穿夹克外套带好雨具。 }] }; return Task.FromResultA2AResponse(message); } private TaskAgentCard GetAgentCardAsync(string agentUrl, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledAgentCard(cancellationToken); } var capabilities new AgentCapabilities() { Streaming true, PushNotifications false, }; return Task.FromResult(new AgentCard() { Name weather agent, Description weather information agent, Url agentUrl, Version 1.0.0, DefaultInputModes [text], DefaultOutputModes [text], Capabilities capabilities, Skills [ new AgentSkill { Id weather-query, Name 天气查询, Description 查询指定城市的天气预报包括温度、降水概率、穿衣建议等, Tags [weather, forecast, climate], Examples [上海明天天气怎么样, 成都这周的天气预报, 杭州下雨吗], InputModes [text], OutputModes [text] }], }); } }这里说明一下这里为了方便是直接返回了一个固定的天气信息输出内容但在实际应用中往往需要进行具体的业务逻辑处理或调用大模型进行处理。下面的几个Agent也是类似的情况就不再赘述。然后在Program.cs中进行注册完成端口映射using A2A; using A2A.AspNetCore; using WeatherAgentServer; var builder WebApplication.CreateBuilder(args); var app builder.Build(); var taskManager new TaskManager(); var agent new WeatherAgent(); agent.Attach(taskManager); // Add JSON-RPC endpoint for A2A app.MapA2A(taskManager, /weather); // Add well-known agent card endpoint for A2A app.MapWellKnownAgentCard(taskManager, /weather); // Add HTTP endpoint for A2A app.MapHttpA2A(taskManager, /weather); app.Run();3.2 酒店Agent创建一个HotelAgent类定义其能力 和 AgentCardpublic class HotelAgent { public void Attach(ITaskManager taskManager) { taskManager.OnMessageReceived QueryHotelsAsync; taskManager.OnAgentCardQuery GetAgentCardAsync; } private TaskA2AResponse QueryHotelsAsync(MessageSendParams messageSendParams, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledA2AResponse(cancellationToken); } // Process the message var messageText messageSendParams.Message.Parts.OfTypeTextPart().First().Text; // Create and return an artifact var message new AgentMessage() { Role MessageRole.Agent, MessageId Guid.NewGuid().ToString(), ContextId messageSendParams.Message.ContextId, Parts [new TextPart() { Text $ **酒店推荐** 根据您的需求为您推荐以下酒店 **豪华型 ⭐⭐⭐⭐⭐** 1. 上海外滩华尔道夫酒店 - 外滩核心位置江景房 - ¥2,500/晚起 - ⭐ 评分 4.9/5.0 **舒适型 ⭐⭐⭐⭐** 2. 上海静安香格里拉大酒店 - 静安寺商圈交通便利 - ¥1,200/晚起 - ⭐ 评分 4.7/5.0 **经济型 ⭐⭐⭐** 3. 全季酒店上海南京路店 - 南京路步行街旁 - ¥380/晚起 - ⭐ 评分 4.5/5.0 提示建议提前预订周末和节假日价格可能上涨 20-50%。 }] }; return Task.FromResultA2AResponse(message); } private TaskAgentCard GetAgentCardAsync(string agentUrl, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledAgentCard(cancellationToken); } var capabilities new AgentCapabilities() { Streaming true, PushNotifications false, }; return Task.FromResult(new AgentCard() { Name hotel-a2a-agent, Description hotel information agent, Url agentUrl, Version 1.0.0, DefaultInputModes [text], DefaultOutputModes [text], Capabilities capabilities, Skills [ new AgentSkill { Id hotel-recommendation, Name 酒店推荐, Description 根据目的地和预算推荐合适的酒店包括豪华型、舒适型、经济型, Tags [hotel, accommodation, booking, travel], Examples [推荐上海的酒店, 上海外滩附近有什么好酒店, 预算500以内的北京酒店], InputModes [text], OutputModes [text] } ], }); } }同样请参考天气Agent完成Program.cs中的注册。3.3 景点Agent创建一个PlanAgent类定义其能力 和 AgentCardpublic class PlanAgent { public void Attach(ITaskManager taskManager) { taskManager.OnMessageReceived QueryPlansAsync; taskManager.OnAgentCardQuery GetAgentCardAsync; } private TaskA2AResponse QueryPlansAsync(MessageSendParams messageSendParams, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledA2AResponse(cancellationToken); } // Process the message var messageText messageSendParams.Message.Parts.OfTypeTextPart().First().Text; // Create and return an artifact var message new AgentMessage() { Role MessageRole.Agent, MessageId Guid.NewGuid().ToString(), ContextId messageSendParams.Message.ContextId, Parts [new TextPart() { Text $ **景点推荐** 为您推荐上海必游景点 **历史文化类** 1. ️ 外滩 - 欣赏万国建筑博览群 2. 豫园 - 江南古典园林代表 3. 城隍庙 - 品尝地道上海小吃 **现代都市类** 4. 东方明珠塔 - 上海地标俯瞰浦江两岸 5. 陆家嘴 - 金融中心上海之巅 6. ️ 南京路步行街 - 购物天堂 **文艺休闲类** 7. 田子坊 - 文艺小店聚集地 8. 武康路 - 梧桐树下的法式风情 9. 世纪公园 - 城市绿肺亲子游首选 建议游玩时间3-4 天可覆盖主要景点 }] }; return Task.FromResultA2AResponse(message); } private TaskAgentCard GetAgentCardAsync(string agentUrl, CancellationToken cancellationToken) { if (cancellationToken.IsCancellationRequested) { return Task.FromCanceledAgentCard(cancellationToken); } var capabilities new AgentCapabilities() { Streaming true, PushNotifications false, }; return Task.FromResult(new AgentCard() { Name plan agent, Description travel plan attraction agent, Url agentUrl, Version 1.0.0, DefaultInputModes [text], DefaultOutputModes [text], Capabilities capabilities, Skills [ new AgentSkill { Id attraction-recommendation, Name 景点推荐, Description 推荐目的地的热门景点和游玩路线包括历史文化、现代都市、文艺休闲等类型, Tags [attraction, sightseeing, tourism, travel], Examples [上海有什么好玩的, 北京必去的景点, 杭州西湖怎么玩], InputModes [text], OutputModes [text] } ], }); } }同样请参考天气Agent完成Program.cs中的注册。3.4 主助手这里我们暂且命名为TravelPlannerClient在该项目中我们需要用到MAF因此我们先安装一下相关NuGet包Microsoft.Extensions.AI.OpenAI Microsoft.Agents.AI.A2A Microsoft.Agents.AI.Abstractions Microsoft.Extensions.AI.Abstractions首先创建一个ChatClient供主助手使用var chatClient new OpenAIClient( new ApiKeyCredential(openAIProvider.ApiKey), new OpenAIClientOptions { Endpoint new Uri(openAIProvider.Endpoint) }) .GetChatClient(openAIProvider.ModelId) .AsIChatClient();其次将远程A2A Agents转换为AIFunction Toolsvar agentEndpoints new[] { https://localhost:7021/a2a, // hotel agent https://localhost:7011/a2a, // weather agent https://localhost:7031/a2a // plan agent }; // Collecting all AI Tools var functionTools new ListAIFunction(); foreach (var endpoint in agentEndpoints) { var resolver new A2ACardResolver(new Uri(endpoint)); var card await resolver.GetAgentCardAsync(); var agent card.AsAIAgent(); // Convert A2A Agent to AIAgent instance functionTools.AddRange(AgentFunctionHelper.CreateFunctionTools(agent, card)); }然后创建一个可以调用A2A Agents的主Agent这一步是核心所在var mainAgent new ChatClientAgent( chatClient: chatClient, instructions: 你是一个智能旅行规划助手。你可以利用可用的工具来帮助用户完成任务。 当用户询问时请使用合适的工具获取信息然后回复用户。 , tools: [.. functionTools] );最后我们可以做下测试// 用户请求 - 测试不同的技能调用 var userRequests new[] { 查询一下上海的天气情况, 推荐一下上海的酒店, 帮我规划一下今日上海的一日游景点并告诉我该如何穿衣服, }; foreach (var userRequest in userRequests) { Console.WriteLine(━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━); Console.WriteLine($ 用户请求: {userRequest}); Console.WriteLine(━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━); // 执行 Agent Console.WriteLine(⏱️ 主 Agent 处理中...); var response await mainAgent.RunAsync(userRequest); Console.WriteLine($ 回答:\n{response.Text}); Console.WriteLine(); }现在我们来看看测试结果case1查询一下上海的天气情况简单任务可以看到主助手通过调用天气Agent获取天气信息完成了回答。case2推荐上海的酒店简单任务可以看到主助手通过调用酒店Agent获取酒店信息完成了回答case3帮我规划一下今日上海的一日游景点并告诉我该如何穿衣服复杂任务