百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 文章教程 > 正文

构建复杂Agent:LangGraph系列分享(三)- Node、Edge、State

yund56 2025-03-17 19:40 22 浏览


LangGraph 通过专注于四个主要组件来简化 AI Agent 开发:

  1. 图形(Graph):这是 LangGraph 的核心架构,如同一张复杂的路线图,涵盖了所有节点以及它们之间的连接关系。它定义了整个系统的结构和信息流动路径。
  2. 状态(State):状态可以被看作是一个共享的数据中心,它记录了整个流程中的关键信息。每个节点都可以读取和写入这个数据中心,从而实现信息的共享和交互。
  3. 节点(Node):节点是图形中的基本单元,类似于一个个独立的站点。每个节点都代表一个特定的任务、操作或检查点,是信息处理和任务执行的具体位置。
  4. (Edge):边是连接节点的通道,决定了信息如何从一个节点流向另一个节点。它定义了节点之间的关系和信息传递的方向,是信息流动的路径。



State 状态:消息的共享中心

在 LangGraph 中,状态应用程序当前快照的共享数据结构,用来存放程序当前数据。它可以是任何类型,通常是 TypedDict 或 Pydantic BaseModel。

主要是给节点之间传递数据的作用。每个节点都可以访问状态和进行读写的操作。当一个节点修改状态时,它会把更新的信息广播到图中的所有其他节点。这种机制使得其他节点对状态的变化而产生不同的输出。

定义一个最简单的状态,当状态中的属性发生变化时,默认会直接覆盖式更新对应的Key。

from typing_extensions import TypedDict

class State(TypedDict):
    # 存储需求描述
    requirement: str
    # 存储测试用例
    test_case: str
    # 存储测试结果
    test_result: str 

当状态中的属性发生变化时,还有另外一种模式。在下面这个例子中,我们使用 TypedDict 定义了一个包含 messages 键的字典。 该键预期持有一个字符串。它指定 messages 是一个Annotated字符串列表。可以有方法 operator.add,表示可以通过将新消息与现有数据append的操作来更新列表。


class State(TypedDict):
    messages: Annotated[List[str], operator.add]


节点(Node)

节点通常是一个Python函数,第一个位置参数是如上所定义的状态。

所以每个节点都可以使用 state["requirement"] 获取状态中 requirement 属性的值。

在 LangGraph 中,节点就像流程中的节点,每个节点都有特定的任务。它们接收输入,进行处理,然后产出输出结果。这些节点能执行各种任务,从简单的数据转换到复杂的决策。

为了更直观地理解节点的工作机制,让我们通过一个简洁的例子来一探究竟:

假设有一个节点负责接收功能需求,经需求分析产出测试用例、再经过另一个节点,负责执行用例、产出测试报告或打回测试。


def case_design(state):
    test_case = "测试用例"
    print(state["test_case"], "完成")
    return {"test_case": test_case}

def run_case(state):
    test_execute = "测试执行"
    print(state["test_case"], "完成")
    return {"test_execute": test_execute}

def test_back(state):
    back = "测试打回"
    print(state["test_result"], "完成")
    return {"test_result": test_back}

def test_report(state):
    report = "测试通过"
    print(state["test_result"], "完成")
    return {"test_result": report}

现在,我们来看看如何将这些节点添加到我们的 LangGraph「图」中:

graph.add_node("case_design_node", case_design)

通过 add_node 方法,我们将这些功能集成到我们的工作流程图中。 每个节点都有一个唯一的名称(如 run_case_node),这样我们就可以在后续的工作流程中明确地引用它们。

另外,LangGraph 内置了 图的两个特殊节点:开始节点(START)、结束节点(END)。

from langgraph.graph import START, END


边(Edge):连接节点的桥梁

在 LangGraph 中,边就如同工作流程中的传送带或决策枢纽。它们规定了信息在节点之间的传递路径以及传递条件。想象一下测试流程:

在测试流程中,边决定着数据或状态应该被传递到哪一个节点。有时候,这是一条直接的传输通道;而有时候,则需要根据数据或状态的具体属性来做出相应的决策。

普通边(显式控制流)

LangGraph允许您通过普通图边显式定义应用程序的控制流(直接连接两个节点)。

最基本的边,直接连接两个节点。 使用 add_edge 方法来添加:

builder.add_edge("case_design", "run_case")

这行代码告诉系统,'case_design' 完成处理后,应该执行 'run_case',同时相关数据或状态也将直接传递给 'run_case' 。

如果要总是 从 node_1 转到 node_2 ,则使用普通边缘。


条件边(动态控制流)

在LangGraph中,也允许您通过LLM或数据状态决定应用程序控制流的部分。这可以通过使用条件边实现。

条件边允许我们根据特定条件选择下一个执行的节点。 使用 add_conditional_edges 方法来添加。

如果您想在节点之间选择路由,则使用条件边。

条件边是作为函数实现的,它根据某些逻辑返回下一个要访问的节点。

import random
from typing import Literal

def decide_mood(state) -> Literal["test_back", "test_report"]:
    
    # 通常,我们将使用state中某个或某些数据的值来决定下一个要访问的节点
    user_input = state['requirement'] 
    
    # Here, let's just do a 50 / 50 split between nodes test_back, test_report
    if random.random() < 0.5:

        # 50% of the time, we return Node 2
        return "test_back"
    
    # 50% of the time, we return Node 3
    return "test_report"

图构建

现在,我们从上面定义的组件,通过StateGraph 构建图形。

首先,我们使用上面定义的 State 类初始化了一个状态图。

然后,我们添加节点和边。

我们使用 START节点,该节点是将用户输入发送到图的特殊节点,以指示在哪里开始我们的图形。

from IPython.display import Image, display
from langgraph.graph import StateGraph, START, END

# Build graph
builder = StateGraph(State)
builder.add_node("case_design", case_design)
builder.add_node("run_case", run_case)
builder.add_node("test_back", test_back)
builder.add_node("test_report", test_report)

# Logic
builder.add_edge(START, "case_design")
builder.add_edge("case_design", "run_case")

builder.add_conditional_edges("run_case", decide_mood)
builder.add_edge("test_back", END)
builder.add_edge("test_report", END)

# Add
graph = builder.compile()

# View
display(Image(graph.get_graph().draw_mermaid_png()))

所构建的图形如下,至此,我们完成了一个简单的Langgraph 图的构建。

下一章节预告:Langgraph中的 Chain、Router。

相关推荐

SM小分队Girls on Top,女神战队少了f(x)?

这次由SM娱乐公司在冬季即将开演的smtown里,将公司的所有女团成员集结成了一个小分队project。第一位这是全面ACE的大姐成员权宝儿(BoA),出道二十年,在日本单人销量过千万,韩国国内200...

韩国女团 aespa 首场 VR 演唱会或暗示 Quest 3 将于 10 月推出

AmazeVR宣布将在十月份举办一场现场VR音乐会,观众将佩戴MetaQuest3进行体验。韩国女团aespa于2020年11月出道,此后在日本推出了三张金唱片,在韩国推出了...

韩网热议!女团aespa成员Giselle在长腿爱豆中真的是legend

身高163的Giselle,长腿傲人,身材比例绝了...

假唱而被骂爆的女团:IVE、NewJeans、aespa上榜

在韩国,其实K-pop偶像并不被认为是真正的歌手,因为偶像们必须兼备舞蹈能力、也经常透过对嘴来完成舞台。由于科技的日渐发达,也有许多网友会利用消音软体来验证K-pop偶像到底有没有开麦唱歌,导致假唱这...

新女团Aespa登时尚大片 四个少女四种style

来源:环球网

韩国女团aespa新歌MV曝光 画面梦幻造型超美

12月20日,韩国女团aespa翻唱曲《DreamsComeTrue》MV公开,视频中,她们的造型超美!WINTER背后长出一双梦幻般的翅膀。柳智敏笑容甜美。宁艺卓皮肤白皙。GISELLE五官精致...

女网友向拳头维权,自称是萨勒芬妮的原型?某韩国女团抄袭KDA

女英雄萨勒芬妮(Seraphine)是拳头在2020年推出的第五位新英雄,在还没有正式上线时就备受lsp玩家的关注,因为她实在是太可爱了。和其他新英雄不同的是,萨勒芬妮在没上线时就被拳头当成虚拟偶像来...

人气TOP女团是?INS粉丝数见分晓;TWICE成员为何在演唱会落泪?

现在的人气TOP女团是?INS粉丝数见分晓!现在爱豆和粉丝之间的交流方法变得多种多样,但是Instagram依然是主要的交流手段。很多粉丝根据粉丝数评价偶像的人气,拥有数百、数千万粉丝的组合作为全球偶...

韩国女团MVaespa Drama MV_韩国女团穿超短裙子跳舞

WelcometoDrama.Pleasefollow4ruleswhilewatchingtheDrama.·1)Lookbackimmediatelywhenyoufe...

aespa师妹团今年将出道! SM职员亲口曝「新女团风格、人数」

记者刘宛欣/综合报导南韩造星工厂SM娱乐曾打造出东方神起、SUPERJUNIOR、少女时代、SHINee、EXO等传奇团体,近年推出的aespa、RIIZE更是双双成为新生代一线团体,深受大众与粉丝...

南韩最活跃的女团aespa,新专辑《Girls》即将发布,盘点昔日经典

女团aespa歌曲盘点,新专辑《Girls》即将发布,期待大火。明天也就是2022年的7月8号,aespa新专辑《Girls》即将发行。这是继首张专辑《Savage》之后,时隔19个月的第二张专辑,这...

章泽天女团aespa出席戛纳晚宴 宋康昊携新片亮相

搜狐娱乐讯(山今/文玄反影/图科明/视频)法国时间5月23日晚,女团aespa、宋康昊、章泽天等明星亮相戛纳晚宴。章泽天身姿优越。章泽天肩颈线优越。章泽天双臂纤细。章泽天仪态端正。女团aespa亮...

Aespa舞台暴露身高比例,宁艺卓脸大,柳智敏有“TOP”相

作为SM公司最新女团aespa,初舞台《BlackMamba》公开,在初舞台里,看得出来SM公司是下了大功夫的,虽然之前SM公司新出的女团都有很长的先导片,但是aespa显然是有“特殊待遇”。运用了...

AESPA女团成员柳智敏karina大美女

真队内速度最快最火达成队内首个且唯一两百万点赞五代男女团中输断层第一(图转自微博)...

对来学校演出的女团成员语言性骚扰?韩国这所男高的学生恶心透了

哕了……本月4日,景福男子高中相关人士称已经找到了在SNS中上传对aespa成员进行性骚扰文章的学生,并开始着手调查。2日,SM娱乐创始人李秀满的母校——景福高中迎来了建校101周年庆典活动。当天,S...