A2A协议确保异构智能体间任务结果可解析、可追溯、可重试:规划智能体用trace_id发起请求并注入callback_url;数据采集智能体执行后构造含status、result、error、metadata的标准响应,调用send_response()发回callback_url;若trace_id或callback_url缺失,结果被丢弃且不重试。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜

腾讯混元多智能体系统中,任务结果的传递必须确保异构智能体间可解析、可追溯、可重试,不能依赖单点内存或临时变量。
通过A2A协议实现结构化结果回传
第一步:在发起任务的智能体(如规划智能体)中,调用A2A客户端发送带唯一trace_id的任务请求,目标地址填写接收方智能体的Agent Card URI(例如:a2a://data-collector@tke-prod-ns)。
第二步:接收方智能体(如数据采集智能体)完成执行后,必须构造标准A2A响应体:包含status(success/failed)、result(JSON序列化结果)、error(失败时必填)、metadata(含source_agent_id、task_id、timestamp)。
第三步:调用A2A客户端的send_response()方法,将响应体发回原始请求头中指定的callback_url,该URL由发起方在初始请求中注入,通常指向其内置的A2A webhook endpoint。
这一步不可跳过——【若未携带原始trace_id或callback_url缺失,结果将被主调度器丢弃且不触发重试】。A2A网关只认这两个字段做路由闭环,其他字段全为可选。
利用腾讯云CMQ消息队列中转结果
方法一:异步解耦模式
在数据采集智能体执行完毕后,直接向CMQ指定队列(如agent-result-queue)发送一条消息,消息Body为纯JSON,必须包含task_id、agent_id、result_payload、timestamp四项。
方法二:带状态确认的可靠投递
调用CMQ SDK的SendMessageBatch接口,将结果打包为batch item,并设置VisibilityTimeout=120秒;报告撰写智能体从队列拉取消息后,必须在120秒内调用DeleteMessage,否则消息会重回队列重复投递。
注意:CMQ不校验JSON schema,【result_payload字段若为非UTF-8编码或含控制字符,会导致下游消费端解析失败且无报错日志】。
经Hy-Memory记忆插件同步中间结果
当任务链路超过3跳(例如:规划→采集→清洗→分析→报告),推荐启用Hy-Memory作为共享上下文枢纽。
数据采集智能体执行完成后,调用Hy-Memory SDK的put_memory()方法,传入memory_key为"task_{task_id}_stage_1_result",value为序列化后的结构化数据,TTL设为7200秒。
后续任一智能体只需调用get_memory("task_{task_id}_stage_1_result")即可获取,无需跨服务网络调用。
这一步操作起来很简单,直接把数据存进去就行,但必须确保memory_key命名规则与上游任务ID强绑定,否则不同任务的结果会相互覆盖。


















