证据到发布的受控任务链

实现与取舍

代码示例

SQLite：本地发布意图与 outbox 同事务

可在空 SQLite 数据库运行。示例只演示本地事务写入发布意图，没有实现权限、审批、消费者、对端幂等与版本变更后的恢复。不能据此宣称端到端 exactly-once。 任何语句失败都必须由调用方回滚整个事务；outbox 插入失败后不能继续提交已经更新的报告状态。

PRAGMA foreign_keys = ON;
CREATE TABLE report (
  tenant_id TEXT NOT NULL,
  report_id TEXT NOT NULL,
  version INTEGER NOT NULL,
  status TEXT NOT NULL CHECK (status IN ('draft', 'publishing', 'published')),
  PRIMARY KEY (tenant_id, report_id)
);
CREATE TABLE publish_outbox (
  tenant_id TEXT NOT NULL,
  action_id TEXT NOT NULL,
  report_id TEXT NOT NULL,
  report_version INTEGER NOT NULL,
  status TEXT NOT NULL DEFAULT 'pending',
  PRIMARY KEY (tenant_id, action_id),
  FOREIGN KEY (tenant_id, report_id) REFERENCES report(tenant_id, report_id)
);
INSERT INTO report VALUES ('tenant-a', 'report-1', 3, 'draft');
BEGIN TRANSACTION;
UPDATE report SET status = 'publishing'
WHERE tenant_id = 'tenant-a' AND report_id = 'report-1'
  AND version = 3 AND status = 'draft';
INSERT INTO publish_outbox (tenant_id, action_id, report_id, report_version)
SELECT 'tenant-a', 'action-1', report_id, version FROM report
WHERE tenant_id = 'tenant-a' AND report_id = 'report-1'
  AND changes() = 1;
COMMIT;
SELECT report_id, report_version, status FROM publish_outbox;

预期输出

report-1|3|pending

工程推演

场景

假设工程场景：资金管理部门要求报告同时引用制度文档与账户流水，并在主管确认后发布。

设计决策

读取接口执行租户权限，数字由确定程序计算，报告和发布审批均绑定版本。

验证目标

目标是每个数字可回放、未批准稿件不可发布、重复消息不产生额外业务动作；尚未作为真实企业效果验证。

适用边界

样例 outbox 仅覆盖本地事务，对端一致性依赖幂等接口或结果核对。

易错点

• 把向量相似度过滤当作权限隔离。
• 认为保存 checkpoint 就能自动保证外部写入一次。
• 将外部服务超时都视为失败并无条件重试。

参考资料

依据公开技术资料设计；参考资料支持技术机制，场景与评分标准为本站设计，不代表某公司面试原题。 新增问答与迁移案例用于原理讲解，来源核查与案例运行验证分别记录。

• LangGraph：持久化与线程检查点
• Temporal：Activity 重试、回执与取消
• MCP：Authorization
• PostgreSQL：事务隔离与一致快照
• AWS：事务 outbox 与重复投递

检查自己理解到哪一步

读完后可以对照这些标准解释原理、边界和取舍。掌握程度由你自评；需要进一步验证时，再完成下方小任务。

基础达标

能拆出检索、查询、生成与审批发布。

中高级信号

明确数据权限、口径、持久化和工具回执。

资深信号

给出容量、成本、故障恢复、灰度与端到端验收。