{"id":3889,"date":"2026-08-29T07:34:37","date_gmt":"2026-08-28T23:34:37","guid":{"rendered":"https:\/\/ai.zhousir.top\/?p=3889"},"modified":"2026-08-29T07:34:37","modified_gmt":"2026-08-28T23:34:37","slug":"langgraph-%e5%9f%ba%e6%9c%ac%e6%a6%82%e5%bf%b5%ef%bc%9astate%e3%80%81node%e3%80%81edge-%e5%85%a5%e9%97%a8","status":"publish","type":"post","link":"https:\/\/ai.zhousir.top\/?p=3889","title":{"rendered":"LangGraph \u57fa\u672c\u6982\u5ff5\uff1aState\u3001Node\u3001Edge \u5165\u95e8"},"content":{"rendered":"
\n
\n

\u4e0a\u7bc7\u4f60\u641e\u6e05\u4e86\u300c\u4e3a\u4f55\u8981 Graph\u300d\u548c\u9009\u578b\u4e09\u53e5\u8bdd\u3002\u8fd9\u7bc7\u662f LangGraph \u4e13\u9898\u7b2c 02 \u7bc7<\/strong>\u2014\u2014\u628a\u4e09\u8981\u7d20\u5199\u8fdb\u4ee3\u7801\uff1a\u7ebf\u6027\u56fe \u2192 \u6761\u4ef6\u8fb9 \u2192 \u5de5\u5177\u73af \u2192 checkpointer\u3002<\/p>\n<\/blockquote>\n

\n

\u5c0f\u660e\u60f3\u628a\u300c\u5fc5\u987b\u62d2\u7b54\u300d\u753b\u6210\u56fe\uff0c\u5374\u4e0d\u77e5\u4ece\u54ea\u4e0b\u7b14<\/span><\/h2>\n

\u9009\u578b\u6284\u8fdb\u672c\u5b50\u540e\uff0c\u5c0f\u660e\u6253\u5f00\u7f16\u8f91\u5668\uff0c\u51c6\u5907\u628a\u5ba2\u670d\u6539\u6210\u56fe\u3002\u76ef\u7740\u7a7a\u767d\u6587\u4ef6\u53d1\u5446\uff1a<\/p>\n

\n

State \u653e\u54ea\u513f\uff1f\u8282\u70b9\u8fd4\u56de\u6574\u4e2a\u5b57\u5178\u8fd8\u662f\u53ea\u8fd4\u56de\u6539\u52a8\u7684\u5b57\u6bb5\uff1f\u6761\u4ef6\u8fb9\u548c if<\/code> \u6709\u5565\u533a\u522b\uff1f<\/p>\n<\/blockquote>\n

\u4ed6\u8dd1\u53bb\u627e\u8001\u5f20\uff1a”\u4ecb\u7ecd\u7bc7\u8bf4 Node \/ Edge \/ State\uff0c\u80fd\u4e0d\u80fd\u4e00\u5929\u4e00\u53f0\u9636\u62c6\u5f00\uff1f”<\/p>\n

\u8001\u5f20\u62c9\u5f00\u6905\u5b50\uff1a”\u53ef\u4ee5\u3002\u4eca\u5929\u6838\u5fc3\u5c31\u4e09\u6837\u2014\u2014\u8282\u70b9\u5e72\u6d3b\u3001\u8fb9\u6307\u8def\u3001\u72b6\u6001\u4f20\u6570\u636e<\/strong>\u3002 Command<\/code>\u3001interrupt<\/code> \u4eca\u5929\u53ea\u70b9\u540d\uff0c\u6df1\u6316\u7559\u7ed9\u5ba2\u670d\u9879\u76ee\u7bc7\u3002”<\/p>\n

\n

\u4e09\u8981\u7d20\uff1a\u4e00\u5f20\u56fe\u8bb0\u4f4f<\/span><\/h2>\n

\u8001\u5f20\u5728\u767d\u677f\u4e0a\u5199\uff1a<\/p>\n

<\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>State  = \u6574\u4e2a\u5de5\u4f5c\u6d41\u91cc\u6d41\u8f6c\u7684\u6570\u636e\uff08TypedDict\uff09\nNode   = \u5173\u952e\u5de5\u4f5c\u4ee3\u7801\uff08\u51fd\u6570\uff09\uff1a\u8bfb State \u2192 \u5e72\u6d3b \u2192 \u8fd4\u56de\u300c\u8981\u66f4\u65b0\u7684\u5b57\u6bb5\u300d\nEdge   = \u8fde\u63a5\u8282\u70b9\u7684\u8def\u5f84\uff1a\u4e32\u884c \/ \u5e76\u884c \/ \u6761\u4ef6\nGraph  = Node + Edge \u7ec4\u6210\u7684\u5de5\u4f5c\u6d41\n<\/code><\/pre>\n
\u6bd4\u55bb\uff1a<\/p>\n
\n
State \u662f\u5171\u4eab\u767d\u677f\uff1b\u6bcf\u4e2a Node \u662f\u6765\u5199\u4e00\u7b14\u7684\u540c\u4e8b\uff1bEdge \u89c4\u5b9a\u4e0b\u4e00\u4f4d\u8c01\u4e0a\u573a\u3002<\/p>\n<\/blockquote>\n\n\n\n\n\n\n\n
\u8fde\u63a5\u65b9\u5f0f<\/th>\n\u542b\u4e49<\/th>\n<\/tr>\n<\/thead>\n
\u4e32\u884c<\/td>\nA \u5b8c\u4e00\u5b9a\u5230 B<\/td>\n<\/tr>\n
\u6761\u4ef6<\/td>\n\u770b State \u518d\u9009\u8def<\/td>\n<\/tr>\n
\u5e76\u884c<\/td>\n\u591a\u8282\u70b9\u540c\u65f6\u8dd1\u518d\u6c47\u805a<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
\u6784\u56fe\u56fa\u5b9a\u56db\u6b65\uff1a<\/p>\n
<\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>StateGraph(State)\n  \u2192 add_node \/ add_edge \/ add_conditional_edges\n  \u2192 compile()\n  \u2192 invoke(...)\n<\/code><\/pre>\n
\n
\u7ebf\u6027\u56fe\u2014\u2014\u8282\u70b9\u8fd4\u56de<\/span><\/h2>\n
\u4e0d\u63a5 LLM\uff0c\u5148\u7ec3\u9aa8\u67b6<\/p>\n
<\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>class<\/span> GraphState<\/span>(TypedDict<\/span>):\n  text: str<\/span>\n  steps: list<\/span>[str<\/span>]\n\n\ndef<\/span> normalize<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n  text = state[\"text\"<\/span>].strip().lower()\n  steps = list<\/span>(state.get(\"steps\"<\/span>) or<\/span> [])\n  steps.append(f\"{len<\/span>(steps) + 1<\/span>}<\/span>.\u89c4\u8303\u5316\u6587\u672c\"<\/span>)\n  return<\/span> {\"text\"<\/span>: text, \"steps\"<\/span>: steps}  # \u53ea\u8fd4\u56de\u8981\u6539\u7684\u5b57\u6bb5<\/span>\n\n\ndef<\/span> shout<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n  steps = list<\/span>(state.get(\"steps\"<\/span>) or<\/span> [])\n  steps.append(f\"{len<\/span>(steps) + 1<\/span>}<\/span>.\u5927\u5199\u6587\u672c\"<\/span>)\n  return<\/span> {\"text\"<\/span>: state[\"text\"<\/span>].upper() + \"!\"<\/span>, \"steps\"<\/span>: steps}\n\n\ndef<\/span> build_graph<\/span>():\n  g = StateGraph(GraphState)\n  g.add_node(\"normalize\"<\/span>, normalize)\n  g.add_node(\"shout\"<\/span>, shout)\n  g.add_edge(START, \"normalize\"<\/span>)\n  g.add_edge(\"normalize\"<\/span>, \"shout\"<\/span>)\n  g.add_edge(\"shout\"<\/span>, END)\n  return<\/span> g.compile<\/span>()\n<\/code><\/pre>\n
\u8001\u5f20\u6572\u9ed1\u677f\uff1a<\/p>\n
    \n
  1. \n
    \u8f93\u5165<\/strong>\u662f\u5b8c\u6574 State\uff1b\u8f93\u51fa<\/strong>\u662f\u90e8\u5206 dict\u2014\u2014\u6846\u67b6\u8d1f\u8d23\u5408\u5e76\u3002<\/section>\n<\/li>\n
  2. \n
    \u4e0d\u8981\u5728\u8282\u70b9\u91cc\u5077\u5077\u6539\u5168\u5c40\u53d8\u91cf\uff1b\u53ef\u6d4b\u3001\u53ef\u6062\u590d\u90fd\u9760\u300c\u8fd4\u56de\u66f4\u65b0\u300d\u3002<\/section>\n<\/li>\n
  3. \n
    START \u2192 normalize \u2192 shout \u2192 END<\/code>\uff1a\u4e32\u884c\u8fb9\uff0c\u8def\u5f84\u5199\u6b7b\u3002<\/section>\n<\/li>\n<\/ol>\n
    \n
    \u6761\u4ef6\u8fb9\u2014\u2014\u628a if\/else \u753b\u6210\u8def\u7531\u8868<\/span><\/h2>\n
    <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>START \u2192 classify \u252c\u2500 weather \u2192 END\n         \u251c\u2500 policy  \u2192 END\n         \u2514\u2500 chitchat \u2192 END\n<\/code><\/pre>\n
    <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>class<\/span> GraphState<\/span>(TypedDict<\/span>):\n    question: str<\/span>\n    route: str<\/span>\n    answer: str<\/span>\n  \ndef<\/span> classify<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n    \"\"\" \u5206\u7c7b\u95ee\u9898 \"\"\"<\/span>\n    q = state[\"question\"<\/span>].lower()\n    if<\/span> any<\/span>(k in<\/span> q for<\/span> k in<\/span> (\"\u5929\u6c14\"<\/span>, \"weather\"<\/span>, \"\u6e29\u5ea6\"<\/span>)): # \u5224\u65ad\u662f\u5426\u5305\u542b\u5929\u6c14\u3001weather\u3001\u6e29\u5ea6<\/span>\n        route = \"weather\"<\/span>\n    elif<\/span> any<\/span>(k in<\/span> q for<\/span> k in<\/span> (\"\u8bf7\u5047\"<\/span>, \"\u5e74\u5047\"<\/span>, \"\u5236\u5ea6\"<\/span>)): # \u5224\u65ad\u662f\u5426\u5305\u542b\u8bf7\u5047\u3001\u5e74\u5047\u3001\u5236\u5ea6<\/span>\n        route = \"policy\"<\/span>\n    else<\/span>: # \u5426\u5219\u4e3a\u95f2\u804a<\/span>\n        route = \"chitchat\"<\/span>\n    return<\/span> {\"route\"<\/span>: route}\n  \ndef<\/span> weather_node<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n    return<\/span> {\"answer\"<\/span>: \"\uff08\u5929\u6c14\u5206\u652f\uff09\u4eca\u65e5\u57f9\u8bad\u57ce\u5e02\uff1a\u6674\uff0c22C\uff08\u6a21\u62df\uff09\"<\/span>}\n\ndef<\/span> policy_node<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n    return<\/span> {\"answer\"<\/span>: \"\uff08\u5236\u5ea6\u5206\u652f\uff09\u8bf7\u67e5\u9605\u8bf7\u5047\u5236\u5ea6\uff1a\u6ee1 1 \u5e74\u5e74\u5047 5 \u5929\uff08\u6837\u4f8b\uff09\u3002\"<\/span>}\n\ndef<\/span> chitchat_node<\/span>(state: GraphState<\/span>) -> dict<\/span>:\n    return<\/span> {\"answer\"<\/span>: \"\uff08\u95f2\u804a\u5206\u652f\uff09\u4f60\u597d\uff0c\u6211\u662f\u8def\u7531\u6f14\u793a\u52a9\u624b\u3002\"<\/span>}\n\ndef<\/span> pick_branch<\/span>(state: GraphState<\/span>) -> Literal<\/span>[\"weather\"<\/span>, \"policy\"<\/span>, \"chitchat\"<\/span>]:\n    return<\/span> state[\"route\"<\/span>]  # type: ignore[return<\/span>-value]<\/span>\n\ndef<\/span> build_graph<\/span>():\n    g = StateGraph(GraphState)\n    g.add_node(\"classify\"<\/span>, classify)\n    g.add_node(\"weather\"<\/span>, weather_node)\n    g.add_node(\"policy\"<\/span>, policy_node)\n    g.add_node(\"chitchat\"<\/span>, chitchat_node)\n    g.add_edge(START, \"classify\"<\/span>)\n    g.add_conditional_edges(\n        \"classify\"<\/span>,\n        pick_branch,\n        {\"weather\"<\/span>: \"weather\"<\/span>, \"policy\"<\/span>: \"policy\"<\/span>, \"chitchat\"<\/span>: \"chitchat\"<\/span>},\n    )\n\n    g.add_edge(\"weather\"<\/span>, END)\n    g.add_edge(\"policy\"<\/span>, END)\n    g.add_edge(\"chitchat\"<\/span>, END)\n\n    return<\/span> g.compile<\/span>()\n\ndef<\/span> run_demo<\/span>() -> None<\/span>:\n    app = build_graph()\n    cases = [\n        \"\u676d\u5dde\u5929\u6c14\u600e\u4e48\u6837\uff1f\"<\/span>,\n        \"\u5e74\u5047\u600e\u4e48\u8bf7\uff1f\"<\/span>,\n        \"\u4f60\u597d\u5440\"<\/span>,\n    ]\n\n    for<\/span> q in<\/span> cases:\n        out = app.invoke({\"question\"<\/span>: q, \"route\"<\/span>: \"\"<\/span>, \"answer\"<\/span>: \"\"<\/span>})\n        print<\/span>(f\"Q: {q}<\/span>\"<\/span>)\n        print<\/span>(f\"  route={out['route'<\/span>]}<\/span> | answer={out['answer'<\/span>]}<\/span>\"<\/span>)\n<\/code><\/pre>\n
    \u8981\u70b9\uff1a<\/p>\n
      \n
    • \n
      classify<\/code> \u5199<\/strong> route<\/code> \u8fdb State\uff1bpick_branch<\/code> \u8bfb<\/strong> State \u51b3\u5b9a\u4e0b\u4e00\u8282\u70b9\u540d\u3002<\/section>\n<\/li>\n
    • \n
      \u6620\u5c04\u8868\u91cc\u7684 key \u5fc5\u987b\u548c\u8def\u7531\u51fd\u6570\u8fd4\u56de\u503c\u5bf9\u5f97\u4e0a\uff1b\u5efa\u8bae Literal<\/code> + \u9ed8\u8ba4\u5206\u652f\u3002<\/section>\n<\/li>\n
    • \n
      \u89c4\u5219\u8def\u7531\u7a33\u3001\u4fbf\u5b9c\uff1b\u6362\u6210 LLM \u5206\u7c7b\u66f4\u61c2\u81ea\u7136\u8bed\u8a00\uff0c\u4f46\u8d35\u3001\u8981\u515c\u5e95\uff08WorkFlow \u7bc7\u518d\u6bd4\uff09\u3002<\/section>\n<\/li>\n<\/ul>\n
      <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>python main.py\n<\/code><\/pre>\n
      <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>Q: \u676d\u5dde\u5929\u6c14\u600e\u4e48\u6837\uff1f\n  route=weather | answer=\uff08\u5929\u6c14\u5206\u652f\uff09\u4eca\u65e5\u57f9\u8bad\u57ce\u5e02\uff1a\u6674\uff0c22C\uff08\u6a21\u62df\uff09\nQ: \u5e74\u5047\u600e\u4e48\u8bf7\uff1f\n  route=policy | answer=\uff08\u5236\u5ea6\u5206\u652f\uff09\u8bf7\u67e5\u9605\u8bf7\u5047\u5236\u5ea6\uff1a\u2026\nQ: \u4f60\u597d\u5440\n  route=chitchat | answer=\uff08\u95f2\u804a\u5206\u652f\uff09\u4f60\u597d\uff0c\u6211\u662f\u8def\u7531\u6f14\u793a\u52a9\u624b\u3002\n<\/code><\/pre>\n
      \n
      \u5de5\u5177\u73af\u2014\u2014\u53ef\u89c1\u7684 ReAct<\/span><\/h2>\n
      \u5c0f\u660e\u6700\u719f\u7684 while tool_calls<\/code>\uff0c\u753b\u6210\u56fe\u5c31\u662f\uff1a<\/p>\n
      <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>START \u2192 agent \u2500\u2500has tool_calls\u2500\u2500\u25ba tools \u2500\u2510\n      \u25b2                \u2502\n      \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500 loop \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518\n      \u2514\u2500 no tool_calls \u2192 END\n<\/code><\/pre>\n
      <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>class<\/span> AgentState<\/span>(TypedDict<\/span>):\n  messages: Annotated[list<\/span>[BaseMessage], add_messages]\n\n@tool<\/span>\ndef<\/span> get_weather<\/span>(city: str<\/span><\/span>) -> str<\/span>:\n    \"\"\"\u67e5\u8be2\u57ce\u5e02\u5929\u6c14\uff08\u6a21\u62df\uff09\u3002\"\"\"<\/span>\n    data = {\"\u676d\u5dde\"<\/span>: \"\u5c0f\u96e8\uff0c17C\"<\/span>, \"\u5317\u4eac\"<\/span>: \"\u6674\uff0c15C\"<\/span>, \"Hangzhou\"<\/span>: \"rain, 17C\"<\/span>}\n    return<\/span> data.get(city, f\"{city}<\/span>\uff1a\u6674\uff0c20C\uff08\u6a21\u62df\uff09\"<\/span>)\n\ntools = [get_weather]\ntool_node = ToolNode(tools) # \u5de5\u5177\u8282\u70b9<\/span>\n\nmodel = ChatOpenAI(\n    model=os.environ.get(\"OPENAI_MODEL\"<\/span>, \"qwen-plus\"<\/span>),\n    api_key=os.environ[\"OPENAI_API_KEY\"<\/span>],\n    base_url=os.environ.get(\"OPENAI_BASE_URL\"<\/span>),\n    temperature=0<\/span>,\n).bind_tools(tools)\n\ndef<\/span> call_model<\/span>(state: AgentState<\/span>) -> dict<\/span>:\n    \"\"\" \u8c03\u7528\u6a21\u578b \"\"\"<\/span>\n    ai = model.invoke(state[\"messages\"<\/span>])\n    return<\/span> {\"messages\"<\/span>: [ai]}\n\ndef<\/span> should_continue<\/span>(state: AgentState<\/span>) -> str<\/span>:\n    \"\"\" \u5224\u65ad\u662f\u5426\u7ee7\u7eed \"\"\"<\/span>\n    last = state[\"messages\"<\/span>][-1<\/span>]\n    # \u5224\u65ad\u662f\u5426\u4e3aAI\u6d88\u606f\u4e14\u6709\u5de5\u5177\u8c03\u7528<\/span>\n    if<\/span> isinstance<\/span>(last, AIMessage) and<\/span> last.tool_calls:\n        return<\/span> \"tools\"<\/span>\n    return<\/span> \"end\"<\/span>\n\ndef<\/span> build_graph<\/span>():\n    g = StateGraph(AgentState)\n    g.add_node(\"agent\"<\/span>, call_model)\n    g.add_node(\"tools\"<\/span>, tool_node)\n    g.add_edge(START, \"agent\"<\/span>)\n    g.add_conditional_edges(\"agent\"<\/span>, should_continue, {\"tools\"<\/span>: \"tools\"<\/span>, \"end\"<\/span>: END})\n    g.add_edge(\"tools\"<\/span>, \"agent\"<\/span>)\n    return<\/span> g.compile<\/span>()\n\ndef<\/span> run_demo<\/span>() -> None<\/span>:\n    app = build_graph()\n    result = app.invoke(\n        {\"messages\"<\/span>: [HumanMessage(content=\"\u676d\u5dde\u5929\u6c14\u600e\u4e48\u6837\uff1f\u7528\u4e00\u53e5\u8bdd\u56de\u7b54\u3002\"<\/span>)]}\n    )\n\n    for<\/span> m in<\/span> result[\"messages\"<\/span>]:\n        t = getattr<\/span>(m, \"type\"<\/span>, \"?\"<\/span>)\n        if<\/span> getattr<\/span>(m, \"tool_calls\"<\/span>, None<\/span>):\n            print<\/span>(f\"[{t}<\/span>] tool_calls={m.tool_calls}<\/span>\"<\/span>)\n        else<\/span>:\n            content = (getattr<\/span>(m, \"content\"<\/span>, \"\"<\/span>) or<\/span> \"\"<\/span>)[:200<\/span>]\n            print<\/span>(f\"[{t}<\/span>] {content}<\/span>\"<\/span>)\n<\/code><\/pre>\n
      \u8001\u5f20\u5f3a\u8c03\u4e24\u5904\uff1a<\/p>\n
        \n
      1. \n
        add_messages<\/code> \u662f reducer<\/strong>\uff1a\u591a\u8f6e\u6d88\u606f\u8ffd\u52a0<\/strong>\uff0c\u4e0d\u662f\u6574\u8868\u8986\u76d6\u3002\u6d88\u606f\u94fe\u573a\u666f\u51e0\u4e4e\u5fc5\u7528\u3002<\/section>\n<\/li>\n
      2. \n
        \u548c create_agent<\/code> \u6bd4\uff1a\u5faa\u73af\u770b\u5f97\u89c1<\/strong>\uff1b\u4e2d\u95f4\u53ef\u63d2\u5ba1\u6838\u3001\u68c0\u7d22\u3001\u9650\u6b65\u8282\u70b9\u3002\u8fdb\u9636\u53ef\u5728 should_continue<\/code> \u91cc\u52a0\u300c\u6700\u591a 3 \u6b65\u300d\u3002<\/section>\n<\/li>\n<\/ol>\n
        <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>python main.py --demo\n<\/code><\/pre>\n
        \u5178\u578b\u8f93\u51fa\u5f62\u72b6\uff08\u5185\u5bb9\u968f\u6a21\u578b\u7565\u6709\u51fa\u5165\uff09\uff1a<\/p>\n
        <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>[human] \u676d\u5dde\u5929\u6c14\u600e\u4e48\u6837\uff1f\u7528\u4e00\u53e5\u8bdd\u56de\u7b54\u3002\n[ai] tool_calls=[...]\n[tool] \u5c0f\u96e8\uff0c17C\n[ai] \u676d\u5dde\u4eca\u5929\u5c0f\u96e8\uff0c\u7ea6 17\u00b0C\u3002\nDay3 OK\n<\/code><\/pre>\n
        \n
        checkpointer + thread_id\u2014\u2014\u56fe\u4e5f\u6709\u77ed\u671f\u8bb0\u5fc6<\/span><\/h2>\n
        <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>class<\/span> ChatState<\/span>(TypedDict<\/span>):\n    messages: Annotated[list<\/span>[BaseMessage], add_messages]\n\ndef<\/span> chatbot<\/span>(state: ChatState<\/span>) -> dict<\/span>:\n    ai = model.invoke(state[\"messages\"<\/span>])\n    return<\/span> {\"messages\"<\/span>: [ai]}\n\ndef<\/span> build_graph<\/span>():\n    g = StateGraph(ChatState)\n    g.add_node(\"chatbot\"<\/span>, chatbot)\n    g.add_edge(START, \"chatbot\"<\/span>)\n    g.add_edge(\"chatbot\"<\/span>, END)\n  return<\/span> g.compile<\/span>(checkpointer=InMemorySaver())\n\ncfg1 = {\"configurable\"<\/span>: {\"thread_id\"<\/span>: \"u1\"<\/span>}}\ncfg2 = {\"configurable\"<\/span>: {\"thread_id\"<\/span>: \"u2\"<\/span>}}\n\napp.invoke({\"messages\"<\/span>: [HumanMessage(content=\"\u6211\u53eb Carol\u3002\"<\/span>)]}, cfg1)\napp.invoke({\"messages\"<\/span>: [HumanMessage(content=\"\u6211\u53eb\u4ec0\u4e48\uff1f\"<\/span>)]}, cfg1)  # \u540c\u7ebf\u7a0b\u8bb0\u5f97<\/span>\napp.invoke({\"messages\"<\/span>: [HumanMessage(content=\"\u6211\u53eb\u4ec0\u4e48\uff1f\"<\/span>)]}, cfg2)  # \u5f02\u7ebf\u7a0b\u4e0d\u4e32<\/span>\n<\/code><\/pre>\n\n\n\n\n\n\n
        \u5199\u6cd5<\/th>\n\u6302\u8f7d\u70b9<\/th>\n<\/tr>\n<\/thead>\n
        create_agent(..., checkpointer=...)<\/code><\/td>\nAgent \u9884\u7ec4\u88c5<\/td>\n<\/tr>\n
        StateGraph.compile(checkpointer=...)<\/code><\/td>\n\u81ea\u5efa\u56fe\uff0c\u540c\u4e00\u5957\u673a\u5236<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
        \u6ca1\u6709 checkpointer\uff1a\u6bcf\u6b21 invoke<\/code> \u4e0d\u4f1a\u81ea\u52a8\u8de8\u8c03\u7528\u6062\u590d\uff0c\u9664\u975e\u4f60\u81ea\u5df1\u4f20\u5165\u5b8c\u6574\u5386\u53f2\u3002\u8bfe\u5802\u7528 InMemorySaver<\/code>\uff1b\u751f\u4ea7\u518d\u6362 Postgres \u7b49\uff08\u9009\u4fee\uff09\u3002<\/p>\n
        <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>python main.py --demo\n<\/code><\/pre>\n
        <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>=== Day4 demo: graph checkpointer + thread_id ===\nthread=u1 | \uff08\u786e\u8ba4\u8bb0\u4f4f Carol \u4e00\u7c7b\u56de\u590d\uff09\nthread=u1 | Carol\uff08\u6216\u7b49\u4ef7\uff09\nthread=u2 | \uff08\u4e0d\u77e5\u9053 \/ \u672a\u5728\u672c\u7ebf\u7a0b\u4ecb\u7ecd\uff09\nDay4 OK\n<\/code><\/pre>\n
        \n
        \u5bf9\u7167\u8868\uff1a\u56db\u5929\u5206\u522b\u7ec3\u4e86\u4ec0\u4e48<\/span><\/h2>\n\n\n\n\n\n\n\n\n
        \u4f60\u7ec3\u5230\u7684\u80fd\u529b<\/th>\n\u4e09\u8981\u7d20\u4fa7\u91cd\u70b9<\/th>\n<\/tr>\n<\/thead>\n
        \u6700\u5c0f\u7ebf\u6027 StateGraph<\/code><\/td>\nState + \u4e32\u884c Edge + \u90e8\u5206\u66f4\u65b0<\/td>\n<\/tr>\n
        add_conditional_edges<\/code><\/td>\n\u6761\u4ef6 Edge \/ \u8def\u7531\u8868<\/td>\n<\/tr>\n
        ToolNode<\/code> + \u5faa\u73af<\/td>\nreducer\uff08add_messages<\/code>\uff09+ \u6761\u4ef6\u73af<\/td>\n<\/tr>\n
        InMemorySaver<\/code> + thread_id<\/code><\/td>\n\u8de8 invoke \u7684 State \u6301\u4e45<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
        \u8fdb\u9636\u540d\u8bcd\uff1a<\/p>\n\n\n\n\n\n\n\n
        \u540d\u8bcd<\/th>\n\u4e00\u53e5\u8bdd<\/th>\n<\/tr>\n<\/thead>\n
        Command<\/code><\/td>\n\u8282\u70b9\u91cc\u540c\u65f6\u66f4\u65b0 State \u5e76\u6307\u5b9a\u4e0b\u4e00\u8df3<\/td>\n<\/tr>\n
        interrupt<\/code><\/td>\n\u6682\u505c\u7ed9\u4eba\u5ba1\uff0c\u518d resume\uff08\u5ba2\u670d\u7bc7 \/ HITL\uff09<\/td>\n<\/tr>\n
        Retry \/ Timeout<\/td>\n\u8282\u70b9\u7ea7\u5931\u8d25\u4e0e\u8d85\u65f6\u7b56\u7565<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
        \n
        \u4e09\u4e2a\u5e38\u89c1\u5751<\/span><\/h2>\n
        \u5751 1\uff1a\u8282\u70b9\u8fd4\u56de\u4e86\u300c\u5b8c\u6574\u65b0 State\u300d\u5374\u6f0f\u5b57\u6bb5<\/span><\/h3>\n
        \u75c7\u72b6<\/strong>\uff1asteps<\/code> \u6216\u5176\u5b83\u952e\u83ab\u540d\u53d8\u7a7a\u3002
        \n\u539f\u56e0<\/strong>\uff1a\u8bef\u4ee5\u4e3a\u5fc5\u987b\u8fd4\u56de\u5168\u91cf\uff1b\u6f0f\u952e\u82e5\u88ab\u5f53\u6210\u8986\u76d6\u4f1a\u51fa\u4e8b\uff08\u89c6 reducer \u800c\u5b9a\uff09\u3002
        \n\u4fee\u6cd5<\/strong>\uff1a\u4e60\u60ef\u53ea\u8fd4\u56de\u53d8\u66f4\u5b57\u6bb5<\/strong>\uff1b\u5217\u8868\u5b57\u6bb5\u81ea\u5df1 list(...)<\/code> \u62f7\u8d1d\u518d\u6539\uff0c\u907f\u514d\u5171\u4eab\u5f15\u7528\u8e29\u5751\u3002<\/p>\n
        \u5751 2\uff1a\u6761\u4ef6\u8fb9\u8fd4\u56de\u503c\u4e0d\u5728\u6620\u5c04\u8868\u91cc<\/span><\/h3>\n
        \u75c7\u72b6<\/strong>\uff1a\u8fd0\u884c\u62a5\u9519\u6216\u8d70\u5230\u610f\u5916\u7ec8\u70b9\u3002
        \n\u539f\u56e0<\/strong>\uff1apick_branch<\/code> \u8fd4\u56de\u4e86 \"Weather\"<\/code> \u800c map \u5199\u7684\u662f \"weather\"<\/code>\u3002
        \n\u4fee\u6cd5<\/strong>\uff1aLiteral<\/code> \u7ea6\u675f\uff1b\u6c38\u8fdc\u7559\u9ed8\u8ba4\u5206\u652f\uff08\u5982 chitchat<\/code>\uff09\u3002<\/p>\n
        \u5751 3\uff1a\u6d88\u606f State \u4e0d\u7528 add_messages<\/code><\/span><\/h3>\n
        \u75c7\u72b6<\/strong>\uff1a\u7b2c\u4e8c\u8f6e\u5bf9\u8bdd\u628a\u5386\u53f2\u76d6\u6389\uff0c\u6216\u7c7b\u578b\u5bf9\u4e0d\u4e0a\u3002
        \n\u539f\u56e0<\/strong>\uff1a\u666e\u901a list<\/code> \u9ed8\u8ba4\u662f\u8986\u76d6\u8bed\u4e49\u3002
        \n\u4fee\u6cd5<\/strong>\uff1amessages: Annotated[list[BaseMessage], add_messages]<\/code>\uff08\u6216 MessagesState<\/code>\uff09\u3002<\/p>\n
        \n
        \u603b\u7ed3<\/span><\/h2>\n
        “\u4e09\u4e2a\u6838\u5fc3\u7406\u89e3\uff1a<\/p>\n
          \n
        1. \n
          \u4e09\u8981\u7d20<\/strong> \u2014\u2014 State \u4f20\u6570\u636e\uff0cNode \u8fd4\u56de\u90e8\u5206\u66f4\u65b0\uff0cEdge \u51b3\u5b9a\u4e0b\u4e00\u6b65\uff08\u4e32\u884c\/\u6761\u4ef6\/\u5e76\u884c\uff09  <\/section>\n<\/li>\n
        2. \n
          \u6784\u56fe\u56db\u6b65<\/strong> \u2014\u2014 StateGraph<\/code> \u2192 \u52a0\u8282\u70b9\u8fb9 \u2192 compile<\/code> \u2192 invoke<\/code>  <\/section>\n<\/li>\n
        3. \n
          \u4ece\u7ba1\u9053\u5230 Agent<\/strong> \u2014\u2014 \u7ebf\u6027\u8fb9 \u2192 \u6761\u4ef6\u8def\u7531 \u2192 \u5de5\u5177\u73af \u2192 checkpointer \u8bb0\u5fc6”<\/section>\n<\/li>\n<\/ol>\n
          LangGraph \u4e13\u9898\u8fdb\u5ea6\uff1a<\/p>\n
          <\/ellipse><\/ellipse><\/ellipse><\/svg><\/section>01 \u4ecb\u7ecd\uff08\u4e3a\u4f55 Graph\uff09\n    \u2193\n02 \u57fa\u672c\u6982\u5ff5\u548c\u5165\u95e8\uff08\u672c\u7bc7\uff09\n    \u2193\n03 \u5e38\u89c1 WorkFlow\uff08\u4e03\u79cd\u7f16\u6392\u6a21\u5f0f\uff09\n    \u2193\n04 \u5ba2\u6237\u652f\u6301 Email Agent\n<\/code><\/pre>\n
          \n
          \u56fe\u4e0d\u662f\u9b54\u6cd5\uff1a\u5b83\u662f\u628a\u4f60\u672c\u6765\u8981\u5199\u7684 if\/while\/\u5b58\u6863\uff0c\u53d8\u6210\u770b\u5f97\u89c1\u3001\u6539\u5f97\u52a8\u3001\u6d4b\u5f97\u7740\u7684\u62d3\u6251\u3002<\/strong><\/p>\n<\/blockquote>\n<\/section>\n","protected":false},"excerpt":{"rendered":"
          \u4e0a\u7bc7\u4f60\u641e\u6e05\u4e86\u300c\u4e3a\u4f55\u8981 Graph\u300d\u548c\u9009\u578b\u4e09\u53e5\u8bdd\u3002\u8fd9\u7bc7\u662f LangGraph \u4e13\u9898\u7b2c 02 \u7bc7\u2014\u2014\u628a\u4e09\u8981\u7d20\u5199\u8fdb\u4ee3 […]<\/p>\n","protected":false},"author":1,"featured_media":3890,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[163,165],"tags":[167,168,170,210],"_links":{"self":[{"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/posts\/3889"}],"collection":[{"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=3889"}],"version-history":[{"count":1,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/posts\/3889\/revisions"}],"predecessor-version":[{"id":3891,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/posts\/3889\/revisions\/3891"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=\/wp\/v2\/media\/3890"}],"wp:attachment":[{"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=3889"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=3889"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/ai.zhousir.top\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=3889"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}