AI Agent 状态持久化：检查点、恢复与副作用

直接回答

AI Agent 状态持久化，是让被中断的工作流在不丢失已授权进度、也不重复危险副作用的前提下继续运行。它不只是保存消息，而是定义恢复契约、原子持久化状态转换、隔离非确定性调用、让外部副作用可幂等或可对账、安全迁移旧状态，并用崩溃测试证明恢复行为。

Checkpoint 只保存某个边界上的数据。它不会自动重启 Worker，不保证 Exactly-once，不验证被记住的事实，也不能证明业务动作正确。

状态持久化不等于长期记忆

执行状态和长期记忆跨越的是不同边界。

不要从 Checkpoint 恢复一条过期订单状态后继续把它当作当前事实。快照可以保存订单 ID 和上次观察到的版本；恢复后必须重新向权威系统核验可变事实。

AI Agent 记忆指南解释什么信息可以成为长期记忆，Agent 记忆与删除权负责保留与删除；本文只讨论执行中断与安全续跑。

先定义恢复契约

只有团队明确“恢复成功”是什么，持久化设计才可测试。

“从中断点继续”仍然不够明确。合格契约必须说明：是在不确定副作用之前恢复，还是在已确认副作用之后继续，或进入需要观察和人工处理的对账状态。

把 Agent 建模为版本化状态机

应持久化显式状态与转换，不要序列化整个进程堆。

{
  "tenant_id": "tenant_42",
  "workflow_id": "refund-review",
  "workflow_version": "3.2.0",
  "run_id": "run_01J...",
  "state_version": 17,
  "status": "waiting_for_approval",
  "next_transition": "execute_refund",
  "input_refs": ["case:8472"],
  "completed_steps": ["load_case", "policy_check", "draft_decision"],
  "pending_effects": [],
  "approval": {
    "required_role": "refund_manager",
    "request_id": "approval_91"
  },
  "budgets": {
    "steps_remaining": 4,
    "cost_remaining": 0.72
  },
  "checkpoint_schema": 2,
  "created_at": "2026-08-09T10:20:00Z"
}

大型输出只存引用，不能在每个快照里重复 Blob。排除凭据和临时 Client Object。应保存解释或复现决定所需的 Policy、Prompt、Model、Tool 和代码 Release ID，但不能假设旧供应商或模型会永久可调用。

每个 Checkpoint 都存在崩溃窗口

外部副作用会形成结果不确定边界。

逐一考虑故障点：

1. Intent 提交前崩溃：恢复时看不到已授权副作用，可以重新规划。
2. Intent 提交后、Tool Call 前崩溃：恢复时使用同一 Key 执行。
3. Tool 已执行、响应返回前崩溃：结果不明确，应按 Key 查询或进入对账。
4. 已收到响应、状态提交前崩溃：重试必须返回同一结果或识别既有 Effect。
5. 状态提交后崩溃：恢复后进入下一状态，不再重复 Effect。

因此，Checkpoint 无法独自保证 Exactly-once。Durable Execution 产品可以协调 Event History 与重试，但应用层副作用仍需明确协议。

选择 Checkpoint 确认语义

只定义保存频率还不够，Runtime 必须说明一次写入相对于下一步骤何时才算持久化。当前 LangGraph 文档提供三种 Durability Mode：

这些名称属于具体框架，但决策本身具有通用性。应把选定模式写进 Release Manifest，在 RPO 中说明可能丢失的窗口，并分别在确认前后注入进程崩溃。sync 可以缩小 Checkpoint 丢失窗口，但仍无法消除外部副作用周围的崩溃间隙。

让副作用可幂等或可对账

每个重要 Tool Call 都需要 Effect Protocol。

effect_key = tenant_id + workflow_id + run_id + logical_step

协议至少持久化：

• 稳定 Effect Key；
• 规范化 Request Hash；
• 目标系统与 Operation；
• planned、executing、confirmed、rejected、ambiguous、compensated 状态；
• Provider Receipt 或 Resource ID；
• Attempt Count 与 Last Error；
• 对账和补偿指令。

不要重试所有异常。认证失败、策略拒绝、无效请求、预算耗尽和不可逆副作用结果不明，通常都应进入不同状态，而非重发请求。

在 Snapshot、Event History 与混合模式之间选择

Snapshot 与 Event History 优化的是不同恢复成本。

Event Sourcing 不会天然更好。只有编排逻辑能相对于已记录事件确定性执行时，Replay 才成立。模型调用、时钟、随机数、网络响应和 Tool Effect 必须被记录，或隔离到受控 Activity；否则新一轮 Replay 可能走向不同分支。

Temporal 文档通过 Event History 与确定性 Replay 描述 Durable Workflow；LangGraph 把 Checkpoint 定义为线程级 Graph State Snapshot，把 Store 定义为跨线程应用数据。二者是不同契约，不是可以互换的产品标签。

Temporal 的 LangGraph Plugin 于 2026 年 7 月进入 Public Preview，它把 Graph Node 映射为 Temporal Activity，让独立 Durable Runtime 在 Worker 丢失后重新调度工作。这进一步说明“保存状态”和“拥有执行恢复责任”属于两个层次。它不证明所有 LangGraph 部署都需要 Temporal；采用前仍要核验 Preview 状态、支持 API、Payload Limit、Retry Policy 与 Migration Behavior。

按契约选择存储，而非照抄架构图

Redis + 关系数据库 + 向量数据库不是成熟度模型。

单一数据库可以是正确起点。当前数据库集成能够同时保存 JSON Checkpoint、Namespace 长期记录与 Vector Index。拆分存储会引入复制延迟、部分失败、权限重复、备份协调和删除传播；只有实测收益超过这些成本时才应加新服务。

WAL 是数据库持久化机制，不是 Agent 架构。PostgreSQL 用 Write-ahead Log 恢复已提交的数据库变化，但它不知道支付 API 是否接受请求，也不知道 Agent 应从哪个语义步骤继续。

控制并发与所有权

除非工作流显式支持并行分支，同一 Run 在任一时刻只能由一个 Owner 推进状态。

使用：

• 基于 state_version 的乐观并发控制；
• 带 Fencing Token 的 Worker Lease；
• 并行结果的 Branch ID 与确定性 Reducer；
• Effect Key 唯一约束；
• 按 Tenant 与 Run 限定的授权；
• 普通重试不能重新打开的单调终态。

UPDATE agent_runs
SET state = :next_state,
    state_version = state_version + 1
WHERE tenant_id = :tenant_id
  AND run_id = :run_id
  AND state_version = :expected_version
  AND status NOT IN ('completed', 'cancelled', 'failed');

更新零行意味着 Worker 已经输掉竞争，或 Run 已关闭。它必须重新读取，不能覆盖较新的状态。

多 Agent 系统也不应共享一个可变 Memory Object。每个分支拥有明确的输入、输出和所有权，通过 Reducer 或能识别冲突写入的 Coordinator 合并。

让旧状态跨 Release 迁移

长任务可能比创建它的代码版本存活更久，因此每个 Checkpoint 都必须保存 Workflow 与 Schema 版本。

发布契约应定义：

1. 支持读取哪些旧 Schema；
2. 如何通过纯函数、已测试的 Migration 升级；
3. Transition 重命名或删除后的兼容规则；
4. 引用的 Tool 或 Model 已下线时如何处理；
5. 无法安全迁移时进入哪个 Quarantine 状态；
6. 新版本写入的 Checkpoint 能否被旧版本回滚读取。

禁止从不可信 Checkpoint 反序列化任意类型。使用受限 Schema，校验字段和大小，必要时验证完整性，并把已存 Model/Tool 文本继续视为不可信数据。

可运行的恢复决策

下面的 Go 标准库程序不执行 Tool，而是先验证持久化契约，再根据证据选择唯一安全的恢复动作：

package main

import (
	"errors"
	"fmt"
)

type EffectStatus string
type RecoveryAction string

const (
	effectNone      EffectStatus = "none"
	effectPlanned   EffectStatus = "planned"
	effectConfirmed EffectStatus = "confirmed"
	effectAmbiguous EffectStatus = "ambiguous"

	actionExecute   RecoveryAction = "execute"
	actionAdvance   RecoveryAction = "advance"
	actionReconcile RecoveryAction = "reconcile"
	actionStop      RecoveryAction = "stop"
)

type Checkpoint struct {
	Status          string
	EffectStatus    EffectStatus
	EffectKey       string
	Attempts        int
	MaxAttempts     int
	SchemaVersion   int
	WorkflowRelease string
	DurabilityMode  string
}

func recoveryAction(checkpoint Checkpoint) (RecoveryAction, error) {
	if checkpoint.SchemaVersion < 1 || checkpoint.WorkflowRelease == "" {
		return "", errors.New("checkpoint identity is incomplete")
	}
	if checkpoint.Attempts < 0 || checkpoint.MaxAttempts < 1 {
		return "", errors.New("invalid attempt budget")
	}
	if checkpoint.DurabilityMode != "sync" &&
		checkpoint.DurabilityMode != "async" &&
		checkpoint.DurabilityMode != "exit" {
		return "", errors.New("unsupported durability mode")
	}
	switch checkpoint.Status {
	case "completed", "cancelled", "failed":
		return actionStop, nil
	case "running":
	default:
		return "", errors.New("unknown workflow status")
	}
	switch checkpoint.EffectStatus {
	case effectConfirmed:
		return actionAdvance, nil
	case effectAmbiguous:
		if checkpoint.EffectKey == "" {
			return actionStop, nil
		}
		return actionReconcile, nil
	case effectPlanned:
		if checkpoint.EffectKey == "" || checkpoint.Attempts >= checkpoint.MaxAttempts {
			return actionStop, nil
		}
		return actionExecute, nil
	case effectNone:
		return actionStop, nil
	default:
		return "", errors.New("unknown effect status")
	}
}

func mustAction(checkpoint Checkpoint, want RecoveryAction) {
	got, err := recoveryAction(checkpoint)
	if err != nil || got != want {
		panic(fmt.Sprintf("got=%q err=%v want=%q", got, err, want))
	}
}

func fixture(effect EffectStatus, key string) Checkpoint {
	return Checkpoint{
		Status:          "running",
		EffectStatus:    effect,
		EffectKey:       key,
		Attempts:        1,
		MaxAttempts:     3,
		SchemaVersion:   2,
		WorkflowRelease: "[email protected]",
		DurabilityMode:  "sync",
	}
}

func main() {
	mustAction(fixture(effectPlanned, "run-7:send"), actionExecute)
	mustAction(fixture(effectAmbiguous, "run-7:send"), actionReconcile)
	mustAction(fixture(effectConfirmed, "run-7:send"), actionAdvance)
	mustAction(fixture(effectPlanned, ""), actionStop)
	fmt.Println("execute=true reconcile=true advance=true missing_key_stopped=true")
}

执行 go run recovery_gate.go，预期输出：

execute=true reconcile=true advance=true missing_key_stopped=true

关键不是“自动继续”，而是明确拒绝：结果不明时必须对账，缺少 Effect Identity 时停止，已确认副作用则推进而不是再次执行。

把恢复作为产品属性测试

Happy Path 不能证明持久化可靠，应建立故障矩阵。

持续观测：

• 按故障点切分的恢复成功率；
• Recovery Time 与 Progress Loss；
• 重复或未追踪 Effect 数；
• 需要人工处理的 Ambiguous Effect；
• 过期或不兼容 Checkpoint 数；
• Checkpoint 写入时延与大小；
• Replay 长度与 Migration 失败；
• Retention 与 Deletion 完成率。

Agent 重启后即使生成了合理答案，只要重复退款或忽略取消，就属于恢复失败。

框架映射，而不是框架锁定

框架文档会变化。Recovery Contract、State Schema、Effect Key 和 Failure Test 应由应用自己管理，使替换后端不会改变业务语义。

常见失败模式

• 只保存 Message Log：对话存在，Pending Effect 和审批状态丢失。
• Checkpoint-after-effect Gap：外部动作成功，崩溃后又执行一次。
• 整体对象序列化：Secret、Client 和不兼容运行时类型进入存储。
• Snapshot 充当业务事实：恢复的旧数据绕过 System of Record。
• 全局 Session Key：Tenant、用户或并行 Run 相互覆盖。
• Last-write-wins Recovery：旧 Worker 覆盖新 Checkpoint。
• History 无上限：没有 Retention 或 Compaction。
• Replay Drift：新代码以不同方式解释旧 Transition。
• Cache 充当权威存储：Cache Eviction 直接变成数据丢失。
• Vector Store 混淆：把语义检索误认为 Workflow Durability。

生产检查清单

• [ ] 每个 Run 包含 Tenant、Workflow、Release、Run 和 State Version。
• [ ] 终态、预算、审批和 Pending Effect 都是显式字段。
• [ ] Checkpoint 原子提交，并执行条件版本更新。
• [ ] 每个外部 Effect 都可幂等、可补偿或可对账。
• [ ] 恢复后重新核验可变业务事实。
• [ ] State Schema 具备兼容与 Quarantine 路径。
• [ ] 安全校验和反序列化持久化内容。
• [ ] Retention 覆盖 Checkpoint、Log、Artifact、Index 与 Backup。
• [ ] Crash Test 覆盖 Effect 与 Commit 边界两侧。
• [ ] Dashboard 暴露 Ambiguous Effect 与 Stuck Run。

相关资源

• AI Agent 记忆：生产架构、生命周期与评测
• AI Agent 记忆与删除权
• 企业 AI Agent：从试点到受治理生产
• Agent 可观测性：Trace、评测与成本
• Agent 记忆
• Agent Runtime

一手资料

• LangGraph Persistence 文档 — 当前 Thread Checkpoint、Cross-thread Store 与 Retention 边界。
• LangGraph Checkpointer 与 Durability Mode — Super-step 边界、Pending Write，以及 sync、async、exit 的确认语义。
• LangGraph Checkpoint 仓库 — Checkpoint、Pending Write、删除与序列化契约。
• Temporal Workflow Execution — Event History、确定性 Replay 与 Durable Workflow。
• Temporal LangGraph Plugin — 2026 年 7 月 Public Preview 集成；产品声明不能外推为通用保证。
• PostgreSQL WAL Reliability — 数据库 Write-ahead Log 能保证什么、不能保证什么。
• AWS：使用 LangGraph 与 DynamoDB 构建 Durable Agent — 另一种 Checkpoint 后端与大 Payload Offload 模式；具体服务能力不构成通用要求。