网站建设工作都包括哪些方面西部数码网站开发管理助手

网站建设工作都包括哪些方面,西部数码网站开发管理助手,色目人,临沂建设企业网站文章介绍了AI Agent中的规划模式#xff0c;这是一种让AI系统能够将复杂目标分解为可执行步骤序列的核心机制。文章通过旅行规划Agent的实战案例#xff0c;分别使用LangChain和LangGraph框架实现规划模式#xff0c;展示了规划模式的目标分解、动态适应、结构化输出和记忆功…文章介绍了AI Agent中的规划模式这是一种让AI系统能够将复杂目标分解为可执行步骤序列的核心机制。文章通过旅行规划Agent的实战案例分别使用LangChain和LangGraph框架实现规划模式展示了规划模式的目标分解、动态适应、结构化输出和记忆功能等核心特性。代码部分详细解释了如何初始化LLM、定义输出解析器、创建提示模板和构建处理链帮助读者理解如何在实际项目中应用规划模式。一简介规划模式的本质在人工智能领域真正的智能不仅表现为对即时刺激的响应更体现在对未来行动的前瞻性思考。规划模式是AI Agent展现高级智能的核心机制它使系统能够将复杂目标分解为可执行的步骤序列从而系统性地从当前状态过渡到期望状态。规划Agent就像一位战略家当面对组织一次国际会议这样的复杂任务时它不会盲目行动而是首先分析现状预算、参与者、时间限制和目标成功的会议体验然后设计一条最优路径。这个过程不是预设的而是动态生成的能够根据环境变化实时调整。规划的双重特性灵活性与可靠性规划模式的精髓在于其适应性。当遇到意外障碍——如关键演讲者取消出席或场地突然不可用——优秀的规划Agent不会崩溃而是将这些新约束纳入考量重新评估并调整策略。这种弹性使AI系统能够在不确定的环境中保持功能。然而并非所有场景都需要完全动态的规划。对于那些解决方案明确且重复性高的任务限制Agent的自主性反而能提高效率和可预测性。这就引出了一个关键决策何时需要探索如何做何时只需执行已知流程规划模式的应用领域规划模式在多个领域展现其价值在业务流程管理中规划Agent可以协调复杂的跨部门项目如产品发布将高级目标转化为具体的任务序列管理依赖关系并优化资源分配。在科学研究中规划模式帮助设计实验方案从假设验证到数据分析创建系统性的研究路径。在教育领域个性化学习路径规划Agent可以根据学生表现动态调整课程内容和学习节奏确保最优学习效果。二案例实战旅行规划 Agent分别使用langchain和langgraph框架创建一个旅行规划Agent它能够根据用户偏好制定详细的旅行计划。三langchain实现from typing import Dict import json from langchain_classic.memory import ConversationBufferMemory from langchain_core.output_parsers import BaseOutputParser from langchain_core.prompts import PromptTemplate # 初始化llm from init_client import init_llm llm init_llm(0.7) # 定义输出解析器将模型输出转换为结构化数据 class TravelPlanParser(BaseOutputParser): def parse(self, text: str) - Dict: try: # 尝试提取JSON部分 start_idx text.find({) end_idx text.rfind(}) 1 if start_idx ! -1 and end_idx ! 0: json_str text[start_idx:end_idx] return json.loads(json_str) else: # 如果没有找到JSON返回原始文本 return {plan: text} except Exception as e: print(f解析错误: {e}) return {plan: text} # 创建规划模板 planning_template 你是一位专业的旅行规划师擅长根据客户需求创建详细的旅行计划。 客户需求 - 目的地{destination} - 旅行时长{duration} - 预算{budget} - 兴趣偏好{interests} - 出行时间{travel_date} 请创建一个详细的旅行计划包括 1. 每日行程安排 2. 推荐景点和活动 3. 餐饮建议 4. 交通方案 5. 预算分配 请以JSON格式返回计划结构如下 {{ daily_itinerary: [ {{ day: 1, activities: [活动1, 活动2], meals: [早餐建议, 午餐建议, 晚餐建议], transportation: 当日交通方案 }} ], budget_breakdown: {{ accommodation: 预算金额, food: 预算金额, activities: 预算金额, transportation: 预算金额 }}, general_tips: [旅行提示1, 旅行提示2] }} # 创建调整模板 adjustment_template 根据新的情况调整旅行计划 原始计划 {original_plan} 新情况/调整需求 {adjustment_request} 请提供调整后的旅行计划保持相同的JSON格式。 # 创建提示模板 planning_prompt PromptTemplate( input_variables[destination, duration, budget, interests, travel_date], templateplanning_template ) adjustment_prompt PromptTemplate( input_variables[original_plan, adjustment_request], templateadjustment_template ) # 使用LCEL语法创建链 planning_chain planning_prompt | llm | TravelPlanParser() adjustment_chain adjustment_prompt | llm | TravelPlanParser() # 创建记忆组件 memory ConversationBufferMemory() # 定义旅行规划Agent类 class TravelPlannerAgent: def __init__(self): self.current_plan None self.planning_chain planning_chain self.adjustment_chain adjustment_chain self.memory memory def create_plan(self, destination, duration, budget, interests, travel_date): 创建初始旅行计划 response self.planning_chain.invoke({ destination: destination, duration: duration, budget: budget, interests: interests, travel_date: travel_date }) self.current_plan response self.memory.save_context( {input: f创建旅行计划到{destination}时长{duration}天预算{budget}}, {output: str(response)} ) return response def adjust_plan(self, adjustment_request): 根据新情况调整计划 if not self.current_plan: return 没有可调整的计划请先创建计划。 response self.adjustment_chain.invoke({ original_plan: str(self.current_plan), adjustment_request: adjustment_request }) self.current_plan response self.memory.save_context( {input: f调整计划{adjustment_request}}, {output: str(response)} ) return response def get_current_plan(self): 获取当前计划 return self.current_plan # 使用示例 if __name__ __main__: # 初始化旅行规划Agent agent TravelPlannerAgent() # 创建初始计划 print(## 创建初始旅行计划 ##) initial_plan agent.create_plan( destination中国北京, duration5天, budget10000元, interests传统文化、美食、古迹, travel_date2026年1月 ) print(初始计划:) print(json.dumps(initial_plan, indent2, ensure_asciiFalse)) # 调整计划 print(\n## 调整旅行计划 ##) adjusted_plan agent.adjust_plan(预算减少到8000元并增加一天行程) print(调整后的计划:) print(json.dumps(adjusted_plan, indent2, ensure_asciiFalse))代码解释整个代码可以分为以下几个主要部分 导入模块引入所需的库。 自定义输出解析器 (TravelPlanParser)一个关键组件用于将大语言模型的原始文本输出转换为机器可读的结构化数据Python字典。 初始化核心组件设置语言模型LLM和提示模板。 创建处理链使用 LangChain 的表达式语法LCEL将提示、模型和解析器串联成两个可执行的“链”——一个用于创建计划一个用于调整计划。 封装 Agent 类 (TravelPlannerAgent)将处理链和状态如当前计划、记忆封装成一个易于使用的类。 执行示例演示如何实例化并使用这个 Agent。 . 自定义输出解析器 (TravelPlanParser) class TravelPlanParser(BaseOutputParser): def parse(self, text: str) - Dict: try: # 尝试提取JSON部分 start_idx text.find({) end_idx text.rfind(}) 1 if start_idx ! -1 and end_idx ! 0: json_str text[start_idx:end_idx] return json.loads(json_str) else: return {plan: text} except Exception as e: print(f解析错误: {e}) return {plan: text} 目的LLM 的输出是纯文本。为了让程序能方便地使用计划内容比如访问某一天的行程我们需要将文本转换为 Python 字典。 工作原理 parse 方法接收 LLM 返回的原始文本。 text.find({) 和 text.rfind(})智能地定位文本中 JSON 格式的开始和结束位置。这很关键因为 LLM 有时会在 JSON 前后添加一些解释性文字如“好的这是为您生成的计划{...}”。 json.loads(json_str)将提取出的 JSON 字符串解析成一个 Python 字典。 try...except这是一个健壮性设计。如果 LLM 的输出格式不正确导致无法解析程序不会崩溃而是将原始文本包装在一个字典中返回保证了流程的连续性。 . 初始化核心组件 # 初始化llm from init_client import init_llm llm init_llm(0.7) # 创建规划模板 planning_template 你是一位专业的旅行规划师... 客户需求 - 目的地{destination} ... 请以JSON格式返回计划结构如下 {{ daily_itinerary: [ ... ], ... }} # 创建提示模板 planning_prompt PromptTemplate( input_variables[destination, duration, budget, interests, travel_date], templateplanning_template ) llm init_llm(0.7): temperature0.7: 这是一个非常重要的参数控制输出的随机性。0.7 意味着模型在生成内容时既有一定的创造性适合规划行程又不会过于天马行空能较好地遵循指令。 提示模板 (planning_template 和 planning_prompt): 角色扮演你是一位专业的旅行规划师... 这部分设定了 LLM 的身份有助于它生成更专业、更相关的回答。 变量占位符{destination}, {duration} 等是占位符稍后会被具体的用户输入替换。 输出格式指令请以JSON格式返回计划... 这是整个规划成功的关键。它明确指示 LLM 必须按照给定的 JSON 结构来组织输出这极大地提高了 TravelPlanParser 解析成功的概率。 PromptTemplate(...) 将这个字符串模板转换成一个 LangChain 对象使其能够被用于 LCEL 链中。 . 创建处理链 # 使用LCEL语法创建链 planning_chain planning_prompt | llm | TravelPlanParser() adjustment_chain adjustment_prompt | llm | TravelPlanParser() 这是 LangChain 表达式语言LCEL的精髓它用管道符 | 来表示数据流向非常直观。 planning_chain 的工作流程 输入一个包含 destination, duration 等键的字典。 planning_prompt接收这个字典将变量填充到模板中生成一个完整的提示字符串。 | (管道)将提示字符串传递给下一个组件。 llm接收提示字符串调用 DeepSeek API生成一个原始文本响应。 | (管道)将文本响应传递给下一个组件。 TravelPlanParser()接收文本将其解析成 Python 字典。 输出一个结构化的 Python 字典。 adjustment_chain 的工作流程完全相同只是它使用的是用于调整计划的提示模板。 . 封装 Agent 类 (TravelPlannerAgent) class TravelPlannerAgent: def __init__(self): self.current_plan None self.planning_chain planning_chain self.adjustment_chain adjustment_chain self.memory ConversationBufferMemory() def create_plan(self, destination, duration, budget, interests, travel_date): response self.planning_chain.invoke({ destination: destination, duration: duration, # ... }) self.current_plan response self.memory.save_context(...) return response 目的将复杂的逻辑封装成一个简单易用的接口。使用者不需要关心内部的链是如何工作的只需要调用 create_plan 或 adjust_plan 方法即可。 __init__: self.current_plan None: 定义一个实例变量来存储当前的计划状态。这使得 Agent 具有了“记忆”能力知道自己在处理哪个计划。 self.memory: 初始化对话记忆虽然本例中未深度使用但在构建更复杂的对话式 Agent 时至关重要。 create_plan 方法: self.planning_chain.invoke({...}): 这是调用 LCEL 链的标准方法。传入一个字典其键与 PromptTemplate 中定义的 input_variables 相匹配。 self.current_plan response: 将生成的计划保存为 Agent 的当前状态。 self.memory.save_context(...): 将本次交互用户输入和AI输出记录到记忆中。 . 执行示例 if __name__ __main__: agent TravelPlannerAgent() # 1. 创建初始计划 initial_plan agent.create_plan(...) print(json.dumps(initial_plan, indent2, ensure_asciiFalse)) # 2. 调整计划 adjusted_plan agent.adjust_plan(预算减少到8000元并增加一天行程) print(json.dumps(adjusted_plan, indent2, ensure_asciiFalse)) if __name__ __main__:: 这是 Python 的标准写法确保这部分代码只在脚本被直接运行时执行而不会在被其他脚本导入时执行。 实例化与调用 创建一个 TravelPlannerAgent 的实例。 调用 create_plan 方法传入旅行需求并打印出结构化的初始计划。json.dumps 用于将 Python 字典格式化为漂亮的 JSON 字符串ensure_asciiFalse 确保中文字符能正常显示。 调用 adjust_plan 方法传入一个新的约束条件“预算减少”并打印出调整后的计划。这完美展示了 Agent 的动态适应性。 总结 这个案例通过一个具体的旅行规划任务生动地展示了 AI 规划模式的几个核心要素 目标导向Agent 的行为由一个高级目标规划旅行驱动。 分解与结构化将复杂任务分解为每日行程、预算等结构化步骤并要求 LLM 以结构化格式JSON输出。 动态适应当环境变化预算调整时Agent 不是从头再来而是在现有计划基础上进行修改体现了规划的灵活性。 模块化设计通过 LCEL 和类的封装代码清晰、可复用易于理解和扩展。这正是一个优秀 AI 系统设计的体现。 这个旅行规划Agent展示了规划模式的核心特性 目标分解将规划旅行这一复杂目标分解为每日行程、餐饮、交通等具体任务 动态适应当情况变化如预算调整时能够重新评估并调整计划 结构化输出生成格式化的旅行计划便于后续处理 记忆功能保留交互历史支持上下文相关的调整四.langgraph实现from typing import Dict, List, Optional, TypedDict, Annotated, Literal import json import operator from langchain_core.messages import HumanMessage, AIMessage, BaseMessage from langchain_core.output_parsers import BaseOutputParser, JsonOutputParser from langchain_core.prompts import PromptTemplate from langgraph.graph import StateGraph, END from langgraph.checkpoint.memory import MemorySaver # 初始化LLM from init_client import init_llm llm init_llm(0.7) # 定义输出解析器将模型输出转换为结构化数据 class TravelPlanParser(BaseOutputParser): def parse(self, text: str) - Dict: try: # 尝试提取JSON部分 start_idx text.find({) end_idx text.rfind(}) 1 if start_idx ! -1 and end_idx ! 0: json_str text[start_idx:end_idx] return json.loads(json_str) else: # 如果没有找到JSON返回原始文本 return {plan: text} except Exception as e: print(f解析错误: {e}) return {plan: text} # 定义用户意图解析结果 class UserIntent(TypedDict): intent: Literal[create, adjust, unknown] destination: Optional[str] duration: Optional[str] budget: Optional[str] interests: Optional[str] travel_date: Optional[str] adjustment_request: Optional[str] # 定义用户意图解析器 class UserIntentParser(JsonOutputParser): def parse(self, text: str) - UserIntent: try: result super().parse(text) # 确保所有必需的字段都存在 if intent not in result: result[intent] unknown return result except Exception as e: print(f用户意图解析错误: {e}) return {intent: unknown} # 定义Agent状态 class AgentState(TypedDict): messages: Annotated[List[BaseMessage], operator.add] current_plan: Optional[Dict] destination: Optional[str] duration: Optional[str] budget: Optional[str] interests: Optional[str] travel_date: Optional[str] adjustment_request: Optional[str] user_intent: Optional[str] # 创建用户意图解析模板 intent_extraction_template 你是一个旅行规划助手需要解析用户的输入确定他们的意图并提取相关信息。 用户输入{user_input} 请分析用户输入确定是创建新的旅行计划还是调整现有计划并提取相关信息。 请以JSON格式返回结果包含以下字段 - intent: 用户意图只能是 create创建新计划或 adjust调整现有计划或 unknown无法确定 - destination: 目的地如果是创建计划 - duration: 旅行时长如果是创建计划 - budget: 预算如果是创建计划 - interests: 兴趣偏好如果是创建计划 - travel_date: 出行时间如果是创建计划 - adjustment_request: 调整请求的具体内容如果是调整计划 示例 输入我想去巴黎玩5天预算1万元喜欢艺术和美食下个月出发 输出{{intent: create, destination: 巴黎, duration: 5天, budget: 1万元, interests: 艺术和美食, travel_date: 下个月, adjustment_request: null}} 输入把预算减少到8000元增加一天行程 输出{{intent: adjust, destination: null, duration: null, budget: null, interests: null, travel_date: null, adjustment_request: 把预算减少到8000元增加一天行程}} # 创建规划模板 planning_template 你是一位专业的旅行规划师擅长根据客户需求创建详细的旅行计划。 客户需求 - 目的地{destination} - 旅行时长{duration} - 预算{budget} - 兴趣偏好{interests} - 出行时间{travel_date} 请创建一个详细的旅行计划包括 1. 每日行程安排 2. 推荐景点和活动 3. 餐饮建议 4. 交通方案 5. 预算分配 请以JSON格式返回计划结构如下 {{ daily_itinerary: [ {{ day: 1, activities: [活动1, 活动2], meals: [早餐建议, 午餐建议, 晚餐建议], transportation: 当日交通方案 }} ], budget_breakdown: {{ accommodation: 预算金额, food: 预算金额, activities: 预算金额, transportation: 预算金额 }}, general_tips: [旅行提示1, 旅行提示2] }} # 创建调整模板 adjustment_template 根据新的情况调整旅行计划 原始计划 {original_plan} 新情况/调整需求 {adjustment_request} 请提供调整后的旅行计划保持相同的JSON格式。 # 创建提示模板 intent_extraction_prompt PromptTemplate( input_variables[user_input], templateintent_extraction_template ) planning_prompt PromptTemplate( input_variables[destination, duration, budget, interests, travel_date], templateplanning_template ) adjustment_prompt PromptTemplate( input_variables[original_plan, adjustment_request], templateadjustment_template ) # 创建意图解析链 intent_extraction_chain intent_extraction_prompt | llm | UserIntentParser() # 定义LangGraph节点函数 def extract_travel_info(state: AgentState): 从消息中提取旅行信息 last_message state[messages][-1] if isinstance(last_message, HumanMessage): content last_message.content # 使用LLM解析用户意图 try: intent_result intent_extraction_chain.invoke({user_input: content}) intent intent_result.get(intent, unknown) if intent create: # 创建新计划的请求 return { user_intent: create, destination: intent_result.get(destination), duration: intent_result.get(duration), budget: intent_result.get(budget), interests: intent_result.get(interests), travel_date: intent_result.get(travel_date), adjustment_request: None } elif intent adjust: # 调整计划的请求 return { user_intent: adjust, adjustment_request: intent_result.get(adjustment_request), destination: None, duration: None, budget: None, interests: None, travel_date: None } else: # 无法确定意图 return { user_intent: unknown, messages: [AIMessage(content抱歉我不太理解您的需求。请明确说明是创建新的旅行计划还是调整现有计划。)] } except Exception as e: print(f解析用户输入时出错: {e}) return { user_intent: unknown, messages: [AIMessage(content抱歉解析您的请求时遇到了问题。请再试一次。)] } return state def create_travel_plan(state: AgentState): 创建旅行计划 response planning_prompt | llm | TravelPlanParser() result response.invoke({ destination: state.get(destination, ), duration: state.get(duration, ), budget: state.get(budget, ), interests: state.get(interests, ), travel_date: state.get(travel_date, ) }) return { current_plan: result, messages: [AIMessage(contentf已创建旅行计划{json.dumps(result, indent2, ensure_asciiFalse)})] } def adjust_travel_plan(state: AgentState): 调整旅行计划 if not state.get(current_plan): return { messages: [AIMessage(content没有可调整的计划请先创建计划。)] } response adjustment_prompt | llm | TravelPlanParser() result response.invoke({ original_plan: json.dumps(state[current_plan], indent2, ensure_asciiFalse), adjustment_request: state.get(adjustment_request, ) }) return { current_plan: result, messages: [AIMessage(contentf已调整旅行计划{json.dumps(result, indent2, ensure_asciiFalse)})] } def handle_unknown_intent(state: AgentState): 处理未知意图 return { messages: [AIMessage(content抱歉我不太理解您的需求。请明确说明是创建新的旅行计划还是调整现有计划。)] } def route_request(state: AgentState): 路由请求到适当的节点 intent state.get(user_intent, unknown) if intent create: return create_plan elif intent adjust: return adjust_plan else: return handle_unknown # 构建LangGraph def build_travel_planner_graph(): 构建旅行规划图 workflow StateGraph(AgentState) # 添加节点 workflow.add_node(extract_info, extract_travel_info) workflow.add_node(create_plan, create_travel_plan) workflow.add_node(adjust_plan, adjust_travel_plan) workflow.add_node(handle_unknown, handle_unknown_intent) # 设置入口点 workflow.set_entry_point(extract_info) # 添加条件边 workflow.add_conditional_edges( extract_info, route_request, { create_plan: create_plan, adjust_plan: adjust_plan, handle_unknown: handle_unknown } ) # 添加结束边 workflow.add_edge(create_plan, END) workflow.add_edge(adjust_plan, END) workflow.add_edge(handle_unknown, END) # 添加内存 memory MemorySaver() return workflow.compile(checkpointermemory) # 定义旅行规划Agent类 class TravelPlannerAgent: def __init__(self): self.graph build_travel_planner_graph() # 打印图的结构可选非常直观 try: print(--- 图结构 ---) self.graph.get_graph().print_ascii() print(\n * 20 \n) except Exception as e: print(f无法打印图结构: {e}) self.config {configurable: {thread_id: travel_planner}} self.current_plan None def create_plan(self, destination, duration, budget, interests, travel_date): 创建初始旅行计划 # 构建用户消息 user_message f创建旅行计划到{destination}时长{duration}天预算{budget}兴趣偏好{interests}出行时间{travel_date} # 运行图 result self.graph.invoke( { messages: [HumanMessage(contentuser_message)], destination: destination, duration: duration, budget: budget, interests: interests, travel_date: travel_date }, configself.config ) self.current_plan result.get(current_plan) return self.current_plan def adjust_plan(self, adjustment_request): 根据新情况调整计划 # 构建用户消息 user_message f调整计划{adjustment_request} # 运行图 result self.graph.invoke( { messages: [HumanMessage(contentuser_message)], adjustment_request: adjustment_request, current_plan: self.current_plan }, configself.config ) self.current_plan result.get(current_plan) return self.current_plan def get_current_plan(self): 获取当前计划 return self.current_plan def chat(self, user_input): 与Agent对话 result self.graph.invoke( { messages: [HumanMessage(contentuser_input)] }, configself.config ) self.current_plan result.get(current_plan) return result[messages][-1].content # 使用示例 if __name__ __main__: # 初始化旅行规划Agent agent TravelPlannerAgent() # 创建初始计划 print(## 创建初始旅行计划 ##) initial_plan agent.create_plan( destination中国北京, duration5天, budget10000元, interests传统文化、美食、古迹, travel_date2026年1月 ) print(初始计划:) print(json.dumps(initial_plan, indent2, ensure_asciiFalse)) # 调整计划 print(\n## 调整旅行计划 ##) adjusted_plan agent.adjust_plan(预算减少到8000元并增加一天行程) print(调整后的计划:) print(json.dumps(adjusted_plan, indent2, ensure_asciiFalse)) # 使用聊天接口 - 测试自然语言输入 print(\n## 使用聊天接口 - 自然语言输入测试 ##) # 测试创建计划的自然语言输入 response1 agent.chat(我想去美国洛杉矶玩7天预算15000元喜欢好莱坞和美食明年春天出发) print(response1) # 测试调整计划的自然语言输入 response2 agent.chat(把预算减少到12000元增加一些购物时间) print(response2)代码解释代码可以分为以下几个主要部分 初始化与核心组件导入库、初始化LLM、定义输出解析器。 状态定义使用 TypedDict 定义Agent在工作流中需要维护和传递的状态。 提示工程设计用于指导LLM完成特定任务的模板。 工作流节点定义图中的每个处理步骤节点。 图构建将节点和边连接起来形成一个完整的工作流图。 Agent封装创建一个用户友好的类来与图进行交互。 使用示例展示如何调用这个Agent。 1. 初始化与核心组件 from init_client import init_llm llm init_llm(0.7) 这部分很简单就是从 init_client.py 文件中导入 init_llm 函数并初始化一个温度为0.7的DeepSeek LLM实例。温度0.7意味着模型在生成文本时会有一定的创造性但不会太离谱。 class TravelPlanParser(BaseOutputParser): # ... 这是一个自定义的输出解析器。LLM在生成JSON格式的旅行计划时有时会在JSON前后加上一些解释性的文字例如好的这是您的旅行计划{...}。这个解析器的作用就是鲁棒地从文本中提取出有效的JSON部分并将其转换为Python字典。如果提取失败它会将原始文本包装在一个字典中返回防止程序崩溃。 class UserIntent(TypedDict): # ... class UserIntentParser(JsonOutputParser): # ... 这是本次改进的核心部分。 UserIntent (TypedDict)它定义了一个数据结构模板用来规范用户意图的解析结果。它明确指出解析结果必须包含 intent 字段值为 create, adjust 或 unknown以及其他可选字段如 destination, budget 等。这为后续的数据处理提供了类型安全保障。 UserIntentParser (JsonOutputParser)这是一个专门用于解析 UserIntent 结构的JSON解析器。它继承自LangChain的 JsonOutputParser确保LLM的输出必须是符合 UserIntent 结构的JSON。 2. 状态定义 class AgentState(TypedDict): messages: Annotated[List[BaseMessage], operator.add] current_plan: Optional[Dict] # ... 其他字段 AgentState 是LangGraph的核心概念。它定义了在整个工作流图中流动的数据包。你可以把它想象成一个“共享的记事本”图中的每个节点都可以读取这个记事本的内容也可以在上面写下新的内容。 messages: 使用 Annotated[List[BaseMessage], operator.add] 是LangGraph的惯用写法。它表示这是一个消息列表每当有新的消息添加进来时它会自动追加到列表的末尾而不是覆盖。这天然地实现了对话记忆功能。 current_plan: 存储当前生成的旅行计划。 destination, duration, ...: 存储从用户输入中解析出的具体旅行信息。 user_intent: 存储解析出的用户意图create 或 adjust。 3. 提示工程 代码中定义了三个关键的提示模板 intent_extraction_template (意图提取模板) 目的这是实现泛化的关键。它的任务是理解用户的自然语言输入。 工作方式它告诉LLM“给你一段用户输入请判断他是想创建新计划还是调整旧计划并把相关的信息如目的地、预算等提取出来用指定的JSON格式返回。” 示例模板中包含了输入和输出的示例这是一种强大的少样本提示技术能极大地提高LLM解析的准确性。 planning_template (规划模板) 目的指导LLM根据已提取的结构化信息目的地、预算等生成一个详细的、符合JSON格式的旅行计划。 adjustment_template (调整模板) 目的指导LLM根据用户的调整请求和已有的旧计划生成一个符合JSON格式的新计划。 4. 工作流节点 节点是图中的基本处理单元每个都是一个Python函数接收 AgentState 作为输入并返回一个字典来更新状态。 def extract_travel_info(state: AgentState): # ... 这是最重要的节点也是本次的焦点。 逻辑 获取最新的用户消息。 调用 intent_extraction_chain由 intent_extraction_prompt | llm | UserIntentParser 组成。 这个链将用户输入发送给LLMLLM根据提示模板返回一个结构化的JSON然后 UserIntentParser 将其解析为 UserIntent 字典。 函数检查解析出的 intent 字段。 如果是 create它就更新状态中的 destination, budget 等字段。 如果是 adjust它就更新状态中的 adjustment_request 字段。 如果是 unknown它就返回一个错误消息。 这个函数将**自然语言理解NLU**的任务完全交给了LLM实现了真正的泛化。 def create_travel_plan(state: AgentState): # ... def adjust_travel_plan(state: AgentState): # ... 这两个节点相对直接。它们从状态中获取 extract_travel_info 节点准备好的数据调用相应的规划链planning_chain 或 adjustment_chain来生成或调整计划并将结果更新到 current_plan 字段中。 5. 图构建 def build_travel_planner_graph(): workflow StateGraph(AgentState) # ... return workflow.compile(checkpointermemory) 这个函数将所有节点和逻辑串联成一个可执行的工作流。 workflow StateGraph(AgentState): 创建一个图并指定其状态结构为 AgentState。 workflow.add_node(...): 将之前定义的函数注册为图中的节点。 workflow.set_entry_point(extract_info): 设置图的入口即任何请求都从 extract_travel_info 节点开始处理。 workflow.add_conditional_edges(...): 这是图的决策逻辑。它从 extract_info 节点出发根据 route_request 函数的返回值该函数检查 state 中的 user_intent 字段决定下一步流向哪个节点create_plan, adjust_plan, 或 handle_unknown。 workflow.add_edge(..., END): 定义了哪些节点是图的终点。 workflow.compile(checkpointermemory): 将图编译成一个可运行的应用。checkpointerMemorySaver() 为图添加了持久化记忆功能。这意味着即使在多次调用之间只要 thread_id 相同图就能记住之前的对话历史和 current_plan。 6. Agent封装 class TravelPlannerAgent: def __init__(self): self.graph build_travel_planner_graph() self.config {configurable: {thread_id: travel_planner}} # ... 这个类为用户提供了一个简洁的API隐藏了LangGraph的复杂性。 __init__: 在初始化时编译好图并设置一个唯一的 thread_id。这个ID是记忆功能的关键所有来自同一个Agent实例的对话都会共享同一个记忆空间。 create_plan, adjust_plan: 这两个方法提供了传统的、程序化的调用方式。它们构造一个明确的请求然后调用 self.graph.invoke() 来执行整个工作流。 chat: 这是最能体现改进成果的方法。用户可以直接输入自然语言如 我想去美国洛杉矶玩7天...chat 方法会将这段话直接喂给图图会自动完成意图识别、信息提取、计划生成等所有步骤并返回最终结果。​最后我在一线科技企业深耕十二载见证过太多因技术卡位而跃迁的案例。那些率先拥抱 AI 的同事早已在效率与薪资上形成代际优势我意识到有很多经验和知识值得分享给大家也可以通过我们的能力和经验解答大家在大模型的学习中的很多困惑。我整理出这套 AI 大模型突围资料包✅AI大模型学习路线图✅Agent行业报告✅100集大模型视频教程✅大模型书籍PDF✅DeepSeek教程✅AI产品经理入门资料完整的大模型学习和面试资料已经上传带到CSDN的官方了有需要的朋友可以扫描下方二维码免费领取【保证100%免费】​​为什么说现在普通人就业/升职加薪的首选是AI大模型人工智能技术的爆发式增长正以不可逆转之势重塑就业市场版图。从DeepSeek等国产大模型引发的科技圈热议到全国两会关于AI产业发展的政策聚焦再到招聘会上排起的长队AI的热度已从技术领域渗透到就业市场的每一个角落。智联招聘的最新数据给出了最直观的印证2025年2月AI领域求职人数同比增幅突破200%远超其他行业平均水平整个人工智能行业的求职增速达到33.4%位居各行业榜首其中人工智能工程师岗位的求职热度更是飙升69.6%。AI产业的快速扩张也让人才供需矛盾愈发突出。麦肯锡报告明确预测到2030年中国AI专业人才需求将达600万人人才缺口可能高达400万人这一缺口不仅存在于核心技术领域更蔓延至产业应用的各个环节。​​资料包有什么①从入门到精通的全套视频教程⑤⑥包含提示词工程、RAG、Agent等技术点② AI大模型学习路线图还有视频解说全过程AI大模型学习路线③学习电子书籍和技术文档市面上的大模型书籍确实太多了这些是我精选出来的④各大厂大模型面试题目详解⑤ 这些资料真的有用吗?这份资料由我和鲁为民博士共同整理鲁为民博士先后获得了北京清华大学学士和美国加州理工学院博士学位在包括IEEE Transactions等学术期刊和诸多国际会议上发表了超过50篇学术论文、取得了多项美国和中国发明专利同时还斩获了吴文俊人工智能科学技术奖。目前我正在和鲁博士共同进行人工智能的研究。所有的视频教程由智泊AI老师录制且资料与智泊AI共享相互补充。这份学习大礼包应该算是现在最全面的大模型学习资料了。资料内容涵盖了从入门到进阶的各类视频教程和实战项目无论你是小白还是有些技术基础的这份资料都绝对能帮助你提升薪资待遇转行大模型岗位。智泊AI始终秉持着“让每个人平等享受到优质教育资源”的育人理念‌通过动态追踪大模型开发、数据标注伦理等前沿技术趋势‌构建起前沿课程智能实训精准就业的高效培养体系。课堂上不光教理论还带着学员做了十多个真实项目。学员要亲自上手搞数据清洗、模型调优这些硬核操作把课本知识变成真本事‌​​​​如果说你是以下人群中的其中一类都可以来智泊AI学习人工智能找到高薪工作一次小小的“投资”换来的是终身受益应届毕业生‌无工作经验但想要系统学习AI大模型技术期待通过实战项目掌握核心技术。零基础转型‌非技术背景但关注AI应用场景计划通过低代码工具实现“AI行业”跨界‌。业务赋能 ‌突破瓶颈传统开发者Java/前端等学习Transformer架构与LangChain框架向AI全栈工程师转型‌。获取方式有需要的小伙伴可以保存图片到wx扫描二v码免费领取【保证100%免费】**​