| 前提 | 源端有变更日志/CDC |
|---|---|
| 步骤 | 清空 → 逐批重放 → 对账 |
| 校验 | 版本数与区间连续性 |
重放顺序
重放顺序
for batch in sorted(all_batches):
merge_dimension(batch) -- 与日常合并同一套逻辑
check: 版本区间连续、无重叠、每键单当前行重放脚本与日常合并共用代码,避免两套逻辑产生差异。
当跟踪规则或来源补全历史时,需要按源端变更日志全量重放:从最早变更点到今天逐批执行合并逻辑,产出完整版本链。
| 前提 | 源端有变更日志/CDC |
|---|---|
| 步骤 | 清空 → 逐批重放 → 对账 |
| 校验 | 版本数与区间连续性 |
for batch in sorted(all_batches):
merge_dimension(batch) -- 与日常合并同一套逻辑
check: 版本区间连续、无重叠、每键单当前行