补数流程是什么

补数（回刷）是发现历史数据有问题后，重算指定日期区间的数据。它与日常调度最大的区别是范围可控、必须参数化：脚本要能接收起止日期，逐日重算并覆盖对应分区。补数前要评估影响范围——哪些下游任务需要跟着重跑、报表与接口缓存要不要刷新、对账口径会不会受影响；补完还要核对结果并留下操作记录。

基本信息

典型使用场景

• 上游源数据修正：只重算受影响的日期区间，不整表重跑
• 口径调整上线：新旧口径并行一段，确认一致后再切换
• 任务失败留下缺口：补上缺失分区，并做行数与指标核对
• 补数窗口超过贴源保留期：先确认上游分区是否还在，再决定方案
• 避开日常调度窗口：补数任务串行执行，避免与调度任务争抢资源

各阶段关注点

补数脚本骨架

-- 逐日重算，日期由外部传参，便于指定区间
INSERT OVERWRITE TABLE dwd_trade_order_di PARTITION (dt='2026-10-05')
SELECT order_id, customer_sk, pay_amt
FROM ods_order
WHERE dt='2026-10-05';       -- 覆盖写入，重跑幂等
-- 补数后核对：行数与关键指标是否符合预期
SELECT count(1), sum(pay_amt) FROM dwd_trade_order_di WHERE dt='2026-10-05';