Skip to main content
本指南涵盖了将深度智能体从本地原型投入生产部署时需要考虑的事项。它将逐步介绍内存范围界定、执行环境配置、添加防护措施以及连接前端。

概述

智能体使用来自内存和执行环境的信息来完成任务。 在生产环境中,有几个基本要素决定了信息如何共享和访问:
  • 线程:单次对话。消息历史记录和临时文件默认限定在线程范围内,不会跨线程传递。
  • 用户:与您的智能体交互的人。内存和文件可以是用户私有的,也可以在用户之间共享。身份和授权来自您的认证层
  • 助手:一个配置好的智能体实例。内存和文件可以绑定到一个助手,也可以在所有助手之间共享。
本页涵盖:

LangSmith 部署

deepagents deploy 打包您的智能体配置——内存、沙箱、技能、MCP 服务器——并将其部署到 LangSmith 部署 将深度智能体投入生产的最快方式是使用 deepagents deploy,它打包您的智能体配置,并通过一条命令将其部署为 LangSmith 部署。或者,您可以直接配置 LangSmith 部署。无论哪种方式,都会为您的智能体配置所需的基础设施:助手线程运行、存储和检查点,因此您无需自行设置。它还为您提供了开箱即用的认证Webhook定时任务可观测性,并且可以通过 MCPA2A 暴露您的智能体。 有关基于 CLI 的方法,请参阅使用 CLI 部署。有关手动设置,请参阅 LangSmith 部署快速入门 除非另有说明,本页上的所有代码片段均使用以下 langgraph.json
langgraph.json
{
  "dependencies": ["."],
  "graphs": {
    "agent": "./agent.py:agent"
  },
  "env": ".env"
}
langgraph.json 是告诉 LangGraph 平台如何构建和运行您的应用程序的配置文件。它位于项目根目录,对于本地开发(使用 langgraph dev)和生产部署都是必需的。关键字段如下:
字段描述
dependencies要安装的包。["."] 将当前目录作为包安装(从 requirements.txtpyproject.tomlpackage.json 读取)。
graphs将图 ID 映射到其代码位置。每个条目是 "<id>": "./<file>:<variable>",其中 <id> 是您通过 API 调用图时使用的名称,<variable> 是从 <file> 导出的已编译图或构造函数。
env包含环境变量(API 密钥、密钥)的 .env 文件路径。这些在构建时设置,在运行时可用。
有关完整的配置选项集(自定义 Docker 步骤、存储索引、认证处理程序等),请参阅应用结构

生产环境注意事项

多租户

当您的智能体服务于多个用户时,您需要处理三个问题:验证每个用户的身份、控制他们可以访问的内容,以及管理智能体代表他们操作时使用的凭据。 三个认证层组合:最终用户认证、智能体代表用户认证和团队 RBAC

用户身份和访问控制

LangSmith 部署支持自定义认证以建立用户身份,并支持授权处理程序来控制对线程、助手和存储命名空间等资源的访问。授权处理程序在认证成功后运行,可以:
  • 为资源添加所有权元数据标签(例如,owner: user_id
  • 返回过滤器,以便用户只能看到自己的资源
  • 对未授权操作返回 HTTP 403 拒绝访问
有关分步教程,请参阅使对话私有化。有关演练,请观看自定义认证视频 您如何界定内存范围执行环境决定了用户之间共享哪些数据。详情请参阅以下部分。

团队访问控制 (RBAC)

LangSmith 的基于角色的访问控制管理您团队中谁可以部署、配置和监控智能体。这与上述最终用户授权是分开的。
角色访问权限
工作区管理员完全权限,包括设置和成员管理
工作区编辑者创建和修改资源,但不能删除运行或管理成员
工作区查看者只读访问
企业版计划提供具有细粒度权限的自定义角色。有关完整的权限模型,请参阅 RBAC 参考

最终用户凭据

当您的智能体需要代表用户调用外部 API(例如,读取他们的 GitHub 仓库、发送 Slack 消息、查询他们的数据仓库)时,您需要一种方式将用户的凭据传递给智能体,而无需硬编码它们。 通过智能体认证的 OAuth。 智能体认证提供了一个托管的 OAuth 2.0 流程。配置一个 OAuth 提供程序,智能体就可以请求限定每个用户范围的令牌。首次使用时,智能体会中断执行并呈现一个 OAuth 同意 URL。用户认证后,智能体使用有效的令牌恢复执行。令牌会自动存储和刷新。
from langchain_auth import Client
from langchain.tools import tool, ToolRuntime

auth_client = Client()

# 在您的智能体工具内部:
@tool
async def github_action(runtime: ToolRuntime):
    """代表用户通过 GitHub 执行操作。"""
    auth_result = await auth_client.authenticate(
        provider="github",
        scopes=["repo", "read:org"],
        user_id=runtime.server_info.user.identity,
    )
    # 使用 auth_result.token 代表用户进行 GitHub API 调用
沙箱的凭据注入。 如果您的智能体在沙箱内运行调用外部 API 的代码,沙箱认证代理可以自动将凭据注入出站请求,因此沙箱代码永远不会收到原始 API 密钥。有关设置详情,请参阅管理密钥 工作区密钥。 对于所有用户共享的 API 密钥(例如,您组织的 LLM 提供商密钥、搜索 API 密钥),请将它们作为工作区密钥存储在 LangSmith 中。详情请参阅管理密钥

异步

基于 LLM 的应用程序是 I/O 密集型的:调用语言模型、数据库和外部服务。异步编程允许这些操作并发运行而不是阻塞,从而提高吞吐量和响应能力。
LangChain 遵循在异步方法名前加 a 前缀的约定(例如,ainvokeabefore_agentastream)。同步和异步变体位于同一个类或命名空间中。
为生产环境构建时:
  • 创建异步工具。 LangChain 在单独的线程中运行同步工具以避免阻塞,但原生异步完全避免了线程开销。
  • 使用异步中间件方法。 自定义中间件应实现异步钩子(例如,abefore_agent 而不是 before_agent)。
  • 对外部资源生命周期使用异步。 创建沙箱或连接 MCP 服务器涉及网络调用,应被等待。这就是为什么配置这些资源的图工厂是异步的。

持久性

深度智能体运行在 LangGraph 上,它提供了开箱即用的持久执行持久化层在每个步骤检查点状态,因此因故障、超时或Human in the Loop暂停而中断的运行会从其最后记录的状态恢复,而无需重新处理之前的步骤。对于生成许多子智能体的长时间运行的深度智能体,这意味着运行中的故障不会丢失已完成的工作。 持久执行:当一个工作进程在运行中崩溃时,另一个工作进程从最新的检查点接管运行 检查点还支持:
  • 无限期中断 Human in the Loop的工作流可以暂停数分钟或数天,并准确地从上次中断的地方恢复。
  • 时间旅行 每个检查点步骤都是一个可以回退的快照,如果出现问题,您可以从较早的状态重放。
  • 安全处理敏感操作。 对于涉及支付或其他不可逆操作的工作流,检查点提供审计跟踪和恢复点,以检查导致操作的确切状态。
LangSmith 部署会自动配置持久化检查点。如果您是自托管,请参阅持久化了解设置说明。

内存

没有内存,每次对话都从头开始。内存让您的智能体能够跨对话保留信息(用户偏好、学习到的指令、过去的经验),从而能够随着时间的推移个性化其行为。有关内存类型的概述,请参阅内存概念指南 短期内存通过检查点限定在单个线程范围内;长期内存通过存储跨线程持久化

范围界定

内存始终跨对话持久化。主要问题是它如何在用户和助手边界之间界定范围。正确的范围取决于谁应该查看和修改数据:
范围命名空间用例示例
用户(推荐默认值)(user_id)每个用户的偏好和上下文”我喜欢简洁的回复”
助手(assistant_id)一个助手的共享指令”帖子限制在 280 个字符以内”
全局(org_id)所有用户和助手的只读策略”永远不要泄露内部定价”
共享内存(助手、用户或组织范围)是提示注入的载体。如果一个用户可以写入另一个用户对话读取的内存,恶意用户可能会将指令注入该共享状态。在适当的地方强制执行只读访问。例如,使组织范围的策略只能通过应用程序代码写入,而不是由智能体本身写入。使用权限以声明方式拒绝写入共享路径,或使用后端策略钩子进行自定义验证逻辑。

配置

在深度智能体中,内存作为文件存储在虚拟文件系统中。默认情况下,文件仅持续一次对话。要持久化它们,请将类似 /memories/ 的路径路由到写入 LangGraph StoreStoreBackend。使用 CompositeBackend 为智能体提供临时暂存空间和持久化的长期内存
下面显示的 rt.server_infort.execution_info 命名空间模式需要 deepagents>=0.5.0
user_id 划分命名空间。每个用户获得自己的私有内存。这是推荐的默认值,因为大多数应用程序部署单个助手。
agent.py
from deepagents import create_deep_agent
from deepagents.backends import CompositeBackend, StateBackend, StoreBackend

agent = create_deep_agent(
    model="google_genai:gemini-3.1-pro-preview",
    backend=CompositeBackend(
        default=StateBackend(),
        routes={
            "/memories/": StoreBackend(
                namespace=lambda rt: (
                    rt.server_info.assistant_id,
                    rt.server_info.user.identity,
                ),
            ),
        },
    ),
    system_prompt="""您在 /memories/ 处有持久化内存。

    在每次对话开始时读取 /memories/instructions.txt 以获取
    累积的知识和偏好。当您学到应该持久化的内容时,
    更新该文件。""",
)
您也可以使用 Store API 从应用程序代码读取和写入存储。有关示例,请参阅高级用法 有关完整的命名空间工厂 API,请参阅命名空间工厂。有关自我改进指令和知识库等内存模式,请参阅长期内存

执行环境

在本地,智能体可以读写磁盘上的文件并直接运行 shell 命令。在生产环境中,您需要考虑隔离性和持久性。正确的设置取决于您的智能体是否需要执行代码:
  • 文件系统后端:如果您的智能体只读写文件,这就足够了。选择符合您持久性需求的后端:临时暂存空间、持久存储,或两者的混合。
  • 沙箱:添加一个带有 execute 工具的隔离容器,用于运行 shell 命令。如果您的智能体需要运行代码、安装包或执行文件 I/O 以外的任何操作,请使用沙箱。

文件系统

根据需要持久化的内容选择后端:
  • StateBackend(默认):临时暂存空间,限定在单个对话范围内。在每个步骤检查点,因此避免写入大文件。
  • StoreBackend:跨对话持久化的存储。使用命名空间工厂界定范围。
  • CompositeBackend:混合两者。默认为临时暂存空间,为特定路径(如 /memories/)提供持久化路由。
有关完整的后端列表以及如何构建自定义后端,请参阅后端
FilesystemBackendLocalShellBackend 直接访问主机。不要在已部署的智能体中使用它们。

沙箱

如果您的智能体需要运行代码(而不仅仅是读写文件),请使用沙箱。沙箱提供文件系统和用于运行 shell 命令的 execute 工具,所有这些都在隔离的容器内。这种隔离也保护了您的主机:如果智能体的代码耗尽内存或崩溃,只有沙箱会受到影响。您的服务器继续运行。

生命周期

关键决策是沙箱存活多久。每次对话都获得一个新的沙箱,还是对话共享一个持久化的环境?
范围沙箱 ID 存储在生命周期示例用例
线程范围线程元数据每次对话全新,TTL 到期后清理每次对话都从干净状态开始的数据分析机器人
助手范围助手配置跨所有对话共享跨对话维护克隆仓库的编码助手
下面的示例使用异步图工厂而不是静态图,因为沙箱需要 thread_idassistant_id 来查找或创建正确的沙箱。图工厂不接收完整的 Runtime(没有 server_infoexecution_info);而是接受 RunnableConfig 并从 config["configurable"] 读取 thread_idassistant_id。工厂是异步的,因为沙箱创建是一个 I/O 密集型操作,需要仅在调用时可用的每次运行信息。
每次对话获得自己的沙箱。图工厂从运行配置中读取 thread_id,因此每个线程自动获得自己的隔离环境。提供商的基于标签的查找处理跨运行的去重。当沙箱 TTL 到期时清理。
agent.py
from daytona import CreateSandboxFromSnapshotParams, Daytona
from deepagents import create_deep_agent
from langchain_core.runnables import RunnableConfig
from langchain_daytona import DaytonaSandbox

client = Daytona()


async def agent(config: RunnableConfig):
    thread_id = config["configurable"]["thread_id"]
    try:
        sandbox = await client.find_one(labels={"thread_id": thread_id})
    except Exception:
        sandbox = await client.create(
            CreateSandboxFromSnapshotParams(
                labels={"thread_id": thread_id},
                auto_delete_interval=3600,  # TTL:空闲时清理
            )
        )
    return create_deep_agent(model="google_genai:gemini-3.1-pro-preview", backend=DaytonaSandbox(sandbox=sandbox))
因为 agent 变量是一个异步函数(而不是已编译的图),服务器将其视为图工厂并在每次运行时调用它,注入配置。工厂通过提供商的基于标签的搜索查找或创建沙箱,并返回一个连接到该沙箱的新智能体图。 使用 langgraph deploy 部署后,使用 SDK 从应用程序代码调用智能体。客户端代码无论范围如何都是相同的。范围完全在上面的智能体工厂中处理,但行为有所不同:
每个线程获得自己的沙箱。同一线程内的后续消息重用相同的沙箱,但新线程总是从干净状态开始,没有来自先前对话的遗留文件或安装的包。
client.py
from langgraph_sdk import get_client

client = get_client(url="<DEPLOYMENT_URL>", api_key="<LANGSMITH_API_KEY>")

# 对话 1:安装 pandas 并分析数据
thread_1 = await client.threads.create()
async for chunk in client.runs.stream(
    thread_1["thread_id"],
    "agent",
    input={"messages": [{"role": "human", "content": "安装 pandas 并分析 sales_data.csv"}]},
    stream_mode="updates",
):
    print(chunk.data)

# 同一对话中的后续消息——pandas 仍然已安装
async for chunk in client.runs.stream(
    thread_1["thread_id"],
    "agent",
    input={"messages": [{"role": "human", "content": "现在绘制结果"}]},
    stream_mode="updates",
):
    print(chunk.data)

# 对话 2:全新沙箱——pandas 未安装,没有来自对话 1 的文件
thread_2 = await client.threads.create()
async for chunk in client.runs.stream(
    thread_2["thread_id"],
    "agent",
    input={"messages": [{"role": "human", "content": "安装了哪些包?"}]},
    stream_mode="updates",
):
    print(chunk.data)

文件传输

沙箱是隔离的容器,因此您的应用程序代码无法直接访问其中的文件。使用 upload_files()download_files() 在沙箱边界移动数据:
  • 在智能体运行前为沙箱提供种子:上传用户文件、技能脚本、配置或持久化内存,以便智能体从一开始就有它需要的内容
  • 智能体完成后检索结果:下载生成的工件(报告、图表、导出)并将更新的内存同步回来以供将来对话使用
有关特定于提供商的文件传输示例,请参阅处理文件。有关提供商设置、安全性和生命周期模式,请参阅完整的沙箱指南
智能体需要执行的技能脚本必须在智能体运行前上传到沙箱中。您可能还想同步内存,以便智能体可以在容器内读取和更新它们。使用带有 before_agentafter_agent 钩子的自定义中间件在沙箱边界移动文件:
agent.py
from deepagents import create_deep_agent
from langchain.agents.middleware import AgentMiddleware, AgentState
from langgraph.runtime import Runtime


def _safe_filename(key: str) -> str:
    """拒绝包含路径遍历或通配符字符的键。"""
    name = key.split("/")[-1]
    if ".." in name or any(c in name for c in ("*", "?")):
        raise ValueError(f"无效的键:{key}")
    return name


class SandboxSyncMiddleware(AgentMiddleware):
    """在存储和沙箱之间同步技能和内存。"""

    def __init__(self, backend: CompositeBackend):
        super().__init__()
        self.backend = backend

    async def abefore_agent(self, state: AgentState, runtime: Runtime) -> None:
        """将技能脚本和内存上传到沙箱。"""
        user_id = runtime.server_info.user.identity  
        store = runtime.store
        files = []
        for item in await store.asearch(("skills", user_id)):
            name = _safe_filename(item.key)
            files.append((f"/skills/{name}", item.value["content"].encode()))
        for item in await store.asearch(("memories", user_id)):
            name = _safe_filename(item.key)
            files.append((f"/memories/{name}", item.value["content"].encode()))
        if files:
            await self.backend.upload_files(files)

    async def aafter_agent(self, state: AgentState, runtime: Runtime) -> None:
        """将更新的内存同步回存储。"""
        user_id = runtime.server_info.user.identity  
        store = runtime.store
        items = await store.asearch(("memories", user_id))
        results = await self.backend.download_files(
            [f"/memories/{item.key}" for item in items]
        )
        for result in results:
            if result.content is not None:
                await store.aput(
                    ("memories", user_id),
                    result.path.split("/")[-1],
                    {"content": result.content.decode()},
                )


backend = CompositeBackend(
    default=DaytonaSandbox(sandbox=sandbox),
    routes={
        "/skills/": StoreBackend(
            rt,
            namespace=lambda rt: ("skills", rt.server_info.user.identity),
        ),
        "/memories/": StoreBackend(
            rt,
            namespace=lambda rt: ("memories", rt.server_info.user.identity),
        ),
    },
)

agent = create_deep_agent(
    model="google_genai:gemini-3.1-pro-preview",
    backend=backend,
    middleware=[SandboxSyncMiddleware(backend)],
)

管理密钥

沙箱是隔离的容器,因此来自主机的环境变量在其中不可用。有两种方式向沙箱代码提供 API 密钥和其他密钥: 认证代理(推荐)。 沙箱认证代理拦截来自沙箱的出站请求并自动注入认证头。沙箱代码正常调用外部 API,代理根据目标主机添加正确的凭据。这意味着 API 密钥永远不会出现在沙箱代码、环境变量或日志中。 沙箱认证代理将凭据注入出站请求,因此密钥永远不会进入沙箱
{
  "proxy_config": {
    "rules": [
      {
        "name": "openai-api",
        "match_hosts": ["api.openai.com"],
        "inject_headers": {
          "Authorization": "Bearer ${OPENAI_API_KEY}"
        }
      },
      {
        "name": "anthropic-api",
        "match_hosts": ["api.anthropic.com"],
        "inject_headers": {
          "x-api-key": "${ANTHROPIC_API_KEY}"
        }
      }
    ]
  }
}
${SECRET_KEY} 引用根据存储在您 LangSmith 工作区设置中的密钥进行解析。在创建引用它们的模板之前,请在那里配置密钥。 工作区密钥。 对于不需要基于代理注入的 API 密钥(例如,智能体服务器本身使用的密钥,而不是沙箱代码),请将它们作为工作区密钥存储在 LangSmith 中。这些在运行时作为环境变量对工作区中的所有智能体可用。
避免通过环境变量或文件上传将密钥传递到沙箱中。智能体可以读取沙箱内任何可访问的文件或环境变量,包括凭据。认证代理将密钥完全排除在沙箱之外。

防护措施

生产环境中的智能体自主运行,这意味着它们可能无限循环、达到速率限制或处理包含敏感信息的用户数据。深度智能体提供两层保护:
  • 权限:声明式的允许/拒绝规则,控制智能体可以读取或写入哪些文件和目录。使用权限将智能体隔离到工作目录、保护敏感文件或强制执行只读内存。
  • 中间件:包装模型和工具调用的钩子,用于速率限制、错误处理和数据隐私。
中间件钩子——before_model、wrap_model_call、wrap_tool_call、after_model——包装智能体循环,使策略在每个相关步骤周围确定性地运行

速率限制

这里的速率限制是指在单次运行内限制智能体自身的 LLM 和工具使用,而不是传入请求的 API 网关速率限制。 没有限制,一个混乱的智能体可以通过循环调用同一个工具或进行数百次模型调用,在几分钟内耗尽您的 LLM API 预算。设置每次运行的模型调用和工具执行上限:
from deepagents import create_deep_agent
from langchain.agents.middleware import ModelCallLimitMiddleware, ToolCallLimitMiddleware

agent = create_deep_agent(
    model="google_genai:gemini-3.1-pro-preview",
    middleware=[
        ModelCallLimitMiddleware(run_limit=50),
        ToolCallLimitMiddleware(run_limit=200),
    ],
)
使用 run_limit 限制单次调用内的调用次数(每次轮次重置)。使用 thread_limit 限制整个对话中的调用次数(需要检查点)。有关完整配置,请参阅 ModelCallLimitMiddlewareToolCallLimitMiddleware

处理错误

并非所有错误都应以相同方式处理。瞬时故障(网络超时、速率限制)应自动重试。LLM 可以恢复的错误(错误的工具输出、解析失败)应反馈给模型。需要人工输入的错误应暂停智能体。有关完整的分解和代码示例,请参阅适当处理错误 中间件处理瞬时情况。模型调用和工具调用各自有自己的重试中间件,具有指数退避。如果您的主要模型提供商完全宕机,回退中间件会切换到替代方案:
from deepagents import create_deep_agent
from langchain.agents.middleware import (
    ModelFallbackMiddleware,
    ModelRetryMiddleware,
    ToolRetryMiddleware,
)

agent = create_deep_agent(
    model="google_genai:gemini-3.1-pro-preview",
    middleware=[
        # 在速率限制、超时和 5xx 错误时重试模型调用
        ModelRetryMiddleware(max_retries=3, backoff_factor=2.0, initial_delay=1.0),
        # 如果主模型完全宕机,回退到替代方案
        ModelFallbackMiddleware("gpt-5.4"),
        # 重试调用外部 API 的特定工具(不是所有工具)
        ToolRetryMiddleware(
            max_retries=2,
            tools=["search", "fetch_url"],
            retry_on=(TimeoutError, ConnectionError),
        ),
    ],
)
ToolRetryMiddleware 限定到特定工具,而不是重试所有工具。失败的文件系统 read_file 不会从重试中受益,但超时的网络搜索可能会。有关完整配置,请参阅 ModelRetryMiddlewareModelFallbackMiddleware

数据隐私

如果您的智能体处理可能包含电子邮件、信用卡号或其他 PII 的用户输入,您可以在它到达模型或存储在日志中之前检测并处理它:
from deepagents import create_deep_agent
from langchain.agents.middleware import PIIMiddleware

agent = create_deep_agent(
    model="google_genai:gemini-3.1-pro-preview",
    middleware=[
        PIIMiddleware("email", strategy="redact", apply_to_input=True),
        PIIMiddleware("credit_card", strategy="mask", apply_to_input=True),
    ],
)
策略包括 redact(替换为 [REDACTED_EMAIL])、mask(部分掩码,如 ****-****-****-1234)、hash(确定性哈希)和 block(引发错误)。您还可以为特定领域的模式编写自定义检测器。 有关完整配置,请参阅 PIIMiddleware 有关可用中间件的完整列表,请参阅预构建中间件

前端

深度智能体使用 useStream 将您的 UI 连接到智能体后端。useStream 是一个前端钩子(适用于 React、Vue、Svelte 和 Angular),可实时从您的智能体流式传输消息、子智能体进度和自定义状态。 在本地,useStream 指向 http://localhost:2024。在生产环境中,将其指向您的 LangSmith 部署并配置重连,以便用户在连接中断时不会丢失进度。
import { useStream } from "@langchain/react";

function App() {
  const stream = useStream<typeof agent>({
    apiUrl: "https://your-deployment.langsmith.dev",
    assistantId: "agent",
    reconnectOnMount: true, // 页面刷新或导航后恢复流
    fetchStateHistory: true, // 挂载时加载完整的线程历史记录
  });
}
reconnectOnMount 会自动接取正在进行的运行。如果用户在智能体工作时刷新页面,他们会看到它继续而不是空白屏幕。fetchStateHistory 加载线程的完整对话历史记录,因此返回的用户会看到之前的消息。 对于生成许多子智能体的深度智能体工作流,在提交时设置较高的 recursionLimit 以避免切断长时间运行的执行:
stream.submit(
  { messages: [{ type: "human", content: text }] },
  {
    streamSubgraphs: true,
    config: { recursionLimit: 10000 },
  },
);
有关深度智能体特有的 UI 模式,如子智能体卡片、待办事项列表和自定义状态渲染,请参阅前端指南