导读：经过前三篇的学习，你已经掌握了Agent开发的基础。本文将带你进入进阶领域，学习如何构建高效、可靠、可扩展的生产级Agent系统。多Agent协作模式顺序协作模式场景：任务需要按固定顺序执行，每个Agent负责一个环节示例：内容创作流水线fromcrewaiimportAgent,Task,Crew# 定义角色researcher=Agent(role='研究员',goal='收集和分析信息',backstory='擅长快速定位高质量资料',verbose=True)writer=Agent(role='作家',goal='基于研究撰写文章',backstory='资深科技作家，文风生动',verbose=True)editor=Agent(role='编辑',goal='审查和优化文章质量',backstory='严格的编辑，注重细节',verbose=True)# 定义任务（顺序执行）task1=Task(description='调研{topic}的最新进展',agent=researcher,expected_output='详细的研究笔记')task2=Task(description='基于研究笔记撰写文章',agent=writer,expected_output='结构完整的文章草稿',context=[task1]# 依赖task1的输出)task3=Task(description='审查并优化文章',agent=editor,expected_output='最终版本的文章',context=[task2]# 依赖task2的输出)# 创建团队crew=Crew(agents=[researcher,writer,editor],tasks=[task1,task2,task3],verbose=2)# 执行result=crew.kickoff(inputs={"topic":"量子计算"})优点：流程清晰，易于调试每个环节可独立优化适合标准化工作流缺点：串行执行，速度较慢某个环节失败会影响整个流程并行协作模式场景：多个子任务可以独立执行，最后汇总结果示例：多角度分析importasynciofromconcurrent.futuresimportThreadPoolExecutorclassParallelAnalysisAgent:"""并行分析Agent"""def__init__(self):self.llm=ChatOpenAI(model="gpt-4")asyncdefanalyze_from_perspective(self,topic:str,perspective:str)-str:"""从特定角度分析主题"""prompt=f""" 请从{perspective}的角度分析：{topic}要求： 1. 列出3-5个关键观点 2. 提供具体案例或数据支持 3. 指出该角度的局限性 """response=awaitself.llm.ainvoke(prompt)returnresponse.contentasyncdefcomprehensive_analysis(self,topic:str)-str:"""综合分析"""perspectives=["技术可行性","商业价值","社会影响","伦理考量","未来趋势"]# 并行执行多个分析任务tasks=[self.analyze_from_perspective(topic,p)forpinperspectives]results=awaitasyncio.gather(*tasks)# 汇总结果summary_prompt=f""" 请综合以下不同角度的分析，生成一份全面的分析报告：{''.join([f'\n\n{p}:{r}'forp,rinzip(perspectives,results)])}要求： 1. 整合各角度的核心观点 2. 指出共识和分歧 3. 给出综合判断和建议 """final_response=awaitself.llm.ainvoke(summary_prompt)returnfinal_response.content# 使用agent=ParallelAnalysisAgent()result=asyncio.run(agent.comprehensive_analysis("AI在医疗中的应用"))优点：速度快，充分利用资源多角度分析更全面某个任务失败不影响其他任务缺点：需要处理并发和同步结果整合可能复杂层次化协作模式场景：有一个Manager Agent负责任务分解和协调，Worker Agents负责执行示例：项目管理AgentfromcrewaiimportAgent,Task,Crew,Process# Manager Agentmanager=Agent(role='项目经理',goal='规划和协调整个项目',backstory='经验丰富的项目经理，善于任务分解和资源分配',verbose=True,allow_delegation=True# 允许委派任务)# Worker Agentsdeveloper=Agent(role='开发工程师',goal='实现功能模块',backstory='全栈工程师，技术全面',verbose=True)designer=Agent(role='UI设计师',goal='设计用户界面',backstory='资深设计师，注重用户体验',verbose=True)tester=Agent(role='测试工程师',goal='确保产品质量',backstory='细致的测试工程师，善于发现bug',verbose=True)# 任务（层次化）project_task=Task(description='完成{project_name}项目',agent=manager,expected_output='完整的项目交付物')# 创建团队（使用层次化流程）crew=Crew(agents=[manager,developer,designer,tester],tasks=[project_task],process=Process.hierarchical,# 层次化流程manager_agent=manager,# 指定Managerverbose=2)result=crew.kickoff(inputs={"project_name":"电商网站"})优点：灵活性强，动态调整Manager可以智能分配任务适合复杂、不确定性高的项目缺点：Manager的决策质量很关键可能出现通信开销辩论式协作模式场景：多个Agent从不同角度提出观点，通过辩论达成共识示例：决策支持系统classDebateAgent:"""辩论式Agent"""def__init__(self):self.llm=ChatOpenAI(model="gpt-4")defdebate(self,topic:str,rounds:int=3)-str:"""进行多轮辩论"""# 初始化两个对立观点pro_argument=self.generate_argument(topic,"support")con_argument=self.generate_argument(topic,"oppose")print(f"正方观点:{pro_argument}\n")print(f"反方观点:{con_argument}\n")# 多轮辩论foriinrange(rounds):print(f"\n=== 第{i+1}轮辩论 ===\n")# 正方反驳pro_rebuttal=self.rebut(pro_argument,con_argument,"support")print(f"正方反驳:{pro_rebuttal}\n")# 反方反驳con_rebuttal=self.rebut(con_argument,pro_argument,"oppose")print(f"反方反驳:{con_rebuttal}\n")pro_argument=pro_rebuttal con_argument=con_rebuttal# 总结辩论，得出结论conclusion=self.summarize_debate(topic,pro_argument,con_argument)returnconclusiondefgenerate_argument(self,topic:str,stance:str)-str:"""生成论点"""stance_text="支持"ifstance=="support"else"反对"prompt=f""" 请从{stance_text}的立场，就以下议题提出论点： 议题：{topic}要求： 1. 提出3个主要论据 2. 每个论据要有逻辑支撑 3. 语言有说服力 """response=self.llm.invoke(prompt)returnresponse.contentdefrebut(self,own_argument:str,opponent_argument:str,stance:str)-str:"""反驳对方观点"""stance_text="正方"ifstance=="support"else"反方"prompt=f""" 你是{stance_text}。请针对对方的观点进行反驳，并强化自己的立场。 你的原观点：{own_argument}对方观点：{opponent_argument}要求： 1. 指出对方观点的漏洞 2. 强化自己的论据 3. 回应可能的质疑 """response=self.llm.invoke(prompt)returnresponse.contentdefsummarize_debate(self,topic:str,pro:str,con:str)-str:"""总结辩论"""prompt=f""" 请总结以下关于"{topic}"的辩论，并给出平衡的结论。 正方观点：{pro}反方观点：{con}要求： 1. 概括双方的核心论点 2. 指出共识和分歧 3. 给出平衡的建议或结论 4. 保持客观中立 """response=self.llm.invoke(prompt)returnresponse.content# 使用debater=DebateAgent()conclusion=debater.debate("是否应该全面禁止AI deepfake技术")print(f"\n最终结论:\n{
