17-03 大目录批量导入
题目
先推导:页面数量、内存占用、批次完整与中断恢复怎样协调。完成时核对:中断后能继续,失败不留下不完整业务批次。
推导与做法
分页结果先进入带 run 编号的 staging,页游标与当前页写入一起提交。进程中断后从 next_page 继续,已经保存的原始页不必重读。
完整发现后,再用一个事务发布正式业务表。演示在正式 INSERT 后抛错,books 仍为零;重试后一次出现三本。分批提交原始材料与整批提交正式状态分别承担不同职责,不能把前两页直接暴露成已经完成的目录。
过程图
%% 每个节点保留输入、执行位置或执行后的实际状态。
flowchart TD
S0["第一页暂存两条,next_page=2"]
S1["重开后继续暂存第三条"]
S0 --> S1
S2["正式发布事务中故障:books仍0"]
S1 --> S2
S3["重试整批发布:books一次出现3条"]
S2 --> S3
classDef default fill:#EEF0FB,stroke:#4657B5,color:#24324A
linkStyle default stroke:#4657B5
实现与运行
查看带注释实现。本题与相关处理函数放在同一章节代码文件中;启动工具负责定位相邻项目和选择题号。
在配套目录的 综合项目与交付/model_project 中运行。先按项目 README 执行 uv sync --locked。
# 使用项目解释器运行本题,题号决定执行哪一组演示。
uv run python "../../学习索引/参考实现/代码/ch17.py" 17-03
程序按题号输出处理后的值、查询结果或状态。先和前面的手算比较,再修改一项输入重跑。
查看本题运行结果
# 与上面的手算状态和题目数值逐项比较。
{
"resume_page": 2,
"business_after_failure": 0,
"business_after_retry": [
[
1,
"A"
],
[
2,
"B"
],
[
3,
"C"
]
]
}