幂等、未知结果与任务恢复

按这个知识点的熟悉程度选择起点。当前层：入门 · 理解原理。完成任务后可以继续下一层；阅读与自检不自动代表掌握。

先补齐必要概念

适合：理解请求与响应，第一次处理写操作重试。

先学：工具调用的结构、授权与业务契约 →

幂等: 同一业务操作重复请求时，不额外产生重复业务效果；保证范围要看服务端实现与有效期。
操作身份: 表示同一次业务意图的稳定标识，与每次网络尝试的标识不同。
Checkpoint: 调用方保存的计算状态，不自动等于外部服务已经发生的事实。
未知结果: 调用方没有拿到可靠回执，既不能断言成功，也不能断言没执行。

原理怎样一步步成立？

持久化意图
在发起动作前保存稳定操作身份与参数。
服务方提交
服务方以自身契约执行与去重。
调用方核对
响应丢失时查询或沿同一身份重试。
更新任务状态
取得可核对回执后确认，无法核对则保留未知状态。

入门 · 理解原理

超时为什么不等于没有发布？

本层目标：能解释响应丢失窗口，并区分尝试次数与业务效果次数。

从一个丢失回信的动作开始

调用方请求发布报告，服务方已经写入记录，但返回回执时连接断开。调用方看到超时，只能说明没有得到可靠结果。如果把它当成“没有发布”，再创建一个新请求，可能产生第二份报告。

保存进度仍然不够

Checkpoint 告诉调用方自己保存到了哪一步，服务方可能已经前进到另一步。两个独立系统没有因为保存了本地状态就自动成为一个事务。难点正是服务方提交后、调用方保存结果前的窗口。

操作身份要表达同一个意图

重复尝试沿用同一个业务操作身份，服务方才能识别这是重试。真正发布新的版本应是新操作。同一个身份却换了参数，要明确拒绝或按契约处理，不能悄悄把新的内容当旧结果返回。

运行实验，观察反例

两份本地 SQLite 文件模拟独立提交与响应丢失；无真实远端、进程终止或网络故障，不证明端到端 exactly-once。

Python 3.10+ · 标准库 · 在你的电脑运行

观察调用方 prepared 与服务方已提交的分歧
沿同一操作身份获取原回执
用同一身份改变内容，验证冲突

下载 idempotency_recovery.py ↓

python3 idempotency_recovery.py

查看完整实验代码

"""Two local SQLite files model independent caller/provider commits.

Not a real remote service, production queue or end-to-end exactly-once proof.
"""
import json
import sqlite3
import tempfile
from pathlib import Path


def provider(path, operation, payload):
    with sqlite3.connect(path) as db:
        db.execute("CREATE TABLE IF NOT EXISTS effects (operation TEXT PRIMARY KEY, payload TEXT NOT NULL, receipt TEXT NOT NULL)")
        # Serializes the read/check/write in this local demonstration.
        db.execute("BEGIN IMMEDIATE")
        existing = db.execute("SELECT payload,receipt FROM effects WHERE operation=?", (operation,)).fetchone()
        if existing:
            if existing[0] != payload:
                raise ValueError("same operation with different payload")
            return existing[1]
        receipt = "receipt:" + operation
        db.execute("INSERT INTO effects VALUES(?,?,?)", (operation, payload, receipt))
        return receipt


def demo():
    with tempfile.TemporaryDirectory() as folder:
        remote, local = Path(folder) / "provider.db", Path(folder) / "caller.db"
        with sqlite3.connect(local) as db:
            db.execute("CREATE TABLE intents(operation TEXT PRIMARY KEY, payload TEXT, status TEXT, receipt TEXT)")
            db.execute("INSERT INTO intents VALUES('publish-1','report-v1','prepared',NULL)")
        first = provider(remote, "publish-1", "report-v1")
        # Simulated response loss: provider committed, caller did not get receipt.
        with sqlite3.connect(local) as db:
            before = db.execute("SELECT status FROM intents").fetchone()[0]
        second = provider(remote, "publish-1", "report-v1")
        with sqlite3.connect(local) as db:
            db.execute("UPDATE intents SET status='confirmed', receipt=?", (second,))
        with sqlite3.connect(remote) as db:
            effects = db.execute("SELECT COUNT(*) FROM effects").fetchone()[0]
        assert before == "prepared" and first == second and effects == 1
        return dict(caller_before_recovery=before, same_receipt=first == second,
                    provider_effects=effects, caller_after_recovery="confirmed")


if __name__ == "__main__":
    print(json.dumps(demo(), sort_keys=True))

本地运行的预期输出

{"caller_after_recovery": "confirmed", "caller_before_recovery": "prepared", "provider_effects": 1, "same_receipt": true}

服务方业务效果只有一条
同意图重试回执一致
远端能力和去重期限需另行核实

查看运行环境、输出和校验记录 →

本层验收任务

画出服务方提交、响应丢失、调用方重试三个时刻，并写下每方知道的事实。

完成后逐条核对

调用方超时后保留未知判断
服务方效果可能已经发生
同一业务意图重试身份不变

保存自己的过程、代码与结果。这里提供验收要求，暂不自动评分或保存课程掌握状态。

收起答案，检查理解

每次重试生成一个新 UUID，是否就实现了幂等？

展开参考推导

没有。新身份会被服务方视为新操作；幂等需要同一业务意图跨尝试保持稳定身份，且服务方原子去重。

面试题：作为知识练习

先独立说明原理、前提与边界，再对照解析。作答与笔记保存到原有账号记录。

工具超时后重试，如何防止重复发信、重复下单或重复发布？高级 · 实现 · 独立作答 →Agent 宕机后如何恢复？Checkpoint 为什么不能保证工具只执行一次？高级 · 实现 · 独立作答 →

本专题的全部关联练习（5 道）

依据与验证范围

原理依据来自公开资料；数字、案例和任务是本站教学设计。离线实验验证本页注明的范围，学习效果仍需通过独立任务与反馈判断。