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

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

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


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。

相关推荐

如何在Office 中编辑 PDF?附详细化步骤

PDF很受欢迎,因为它能在不同的设备和操作系统上仍然保持原有格式。但是,这也意味着直接更改PDF文件比其他格式更难更复杂。值得庆幸的是,Microsoftoffice和UPDF帮你解决这一难题。一...

我的 Windows 装机必备软件清单

今天给大家分享下我的装机必备软件,都是用了好多年的软件神器。靠谱、好用、无广告,Windows电脑必备软件,收藏这一篇就够了!01.浏览器王者:Chromehttps://www.google.c...

Docnet Core 是一个轻量级、高性能的 .NET PDF 操作库

DocnetCore介绍DocnetCore是一个轻量级、高性能的.NETPDF操作库,依托于PDFium渲染引擎,提供强大的PDF文档解析、渲染、操作等功能。它完全支持.NET...

分享三款好用的PDF编辑软件,轻松处理PDF

作为一名需要经常和PDF文件打交道的工作者,我来分享一下几款好用的PDF编辑软件,并详细分析了它们的优缺点,希望能帮你找到合适的工具。1.AdobeAcrobatDC作为PDF格式的发明者,Ado...

PDF文档创建工具软件:novaPDF OEM 11.9 Build 432 for Windows

novaPDFOEM是一款实用高效的软件,从头开始设计,让您尽可能轻松地在应用程序中添加PDF打印功能。换句话说,这个实用程序是专门为应用程序开发人员设计的,可以直接在程序安装程序中集成为PDF打印...

线性表顺序存储结构求集合的并,交,补,差(源代码附上 超详细)

一:算法分析1)用数组A,B,C,E表示集合。假定A={1,3,4,5,6,7,9,10},  B={2,,3,4,7,8,10},E={1,2,3,4,5,6,7,8,9,10},  输入数组A...

分享一套SpringBoot开发博客系统源码,包含完整开发文档和视频

基本信息项目名称:eblog摘要:eblog是一个基于Springboot2.1.2开发的博客学习项目,为了让项目融合更多的知识点,达到学习目的,编写了详细的从0到1开发文档。主要学习包括:自定义Fr...

通达信指标合集〔源码齐全〕

很多朋友问到我哪款指标好用,这里我说一下,之所以有很多不同的指标是因为我们在针对不同的盘面情况的时候使用的指标是不同的,我给到的指标一般来讲就目前的环境来讲都是比较适合的,今天我就把我平时自己常用的指...

巅峰对决!Spring Boot VS .NET 6

SpringBoot和ASP.NETCore都是企业中流行的Web框架,对于喜欢C#的人会使用ASP.NETCore,而对于Java或Kotlin等基于JVM的语...

在asp.net core 中控制访问权限的方法

Intro#由于项目需要,需要在基于asp.netmvc的Web项目框架中做权限的控制,于是才有了这个权限控制组件,最初只是支持netframework,后来dotnetcore2.0...

ASP.NET是否无生存之地?

ASP.NET,这个已经很久的技术,总觉得已经被时代淘汰,我们公司是一个10人小公司,几个十年十五年的项目还是用ASP.NET开发的。这两年由于客户的需求变化,我们公司也顺势开始对这些项目重新开发,改...

Spring Boot + Vue.js 实现前后端分离(附源码)

作者:梁小生0101链接:juejin.im/post/5c622fb5e51d457f9f2c2381SpringBoot+Vue.js前后端涉及基本概念介绍,搭建记录,本文会列举出用到环...

ASP.NET Core 中的 Mapster 使用入门教程

在本文中,我们将学习如何在ASP.NETCore应用程序中使用Mapster。首先,我们将了解Mapster是什么以及如何将其安装到.NETCore应用程序中。然后,我们将在使用...

Asp.net常用方法及request和response-a

asp.net教程asp.net常用方法:1、Request.UrlReferrer请求的来源,可以根据这个判断从百度搜的哪个关键词、防下载盗链、防图片盗链,可以伪造(比如迅雷)。(使用全局一般处理...

ASP.NET Core使用功能开关控制路由访问

前言在前面的文章,我们介绍了使用Middleware有条件地允许访问路由(《ASP.NETCore使用Middleware有条件地允许访问路由》)。而对于一些试验性的功能,我们并不希望用密码去控制是...