用途:面向数据工程中高风险的回填与历史重处理操作,在编排执行步骤前加载,作为硬性闸门阻止未规划的重复运行、分区删除或发布路径开启。
适用场景:运行 /backfill 或任何历史重处理请求;修复失败或部分发布窗口;事故后重放事件或分区;变更需重算的转换逻辑;在数据窗口重叠时切换到新管道行为。
主要能力与流程:先停止执行,可用时运行 hooks/backfill-guard.sh 或 hooks/backfill-guard.ps1。依据 templates/backfill-plan.yaml 起草重放计划,明确受影响时间窗口与分区、真实来源与下游目标、执行模式(重放、合并、覆盖)与幂等性证明、发布暂停状态与下游通知、回滚策略、带阈值的校验检查及所需审批。区分增量与回填语义,确认并发限制、水位或游标行为不会跳过或重复迟到数据、指标定义在重放窗口内可比、下游消费者知晓发布暂停。
发布重开前定义对账闸门:行数或体量在阈值内一致、业务键去重检查、关键聚合指标对账、模式与可空性契约检查;正确性需被证明时加载 data-reconciliation-and-financial-controls。按场景加载配套技能:切换或双跑用 data-migration-and-platform-cutover;事故驱动重放用 incident-triage-and-pipeline-recovery;调度或依赖变更用 orchestration-and-backfills。
执行要求:在受限切片中执行,顺序为尽量先干跑或单分区验证,切片对账通过后再扩展到全窗口,所有闸门通过后才重开发布;发布相关时在 templates/release-gate-evidence.yaml 记录证据。提供回填闸门清单跟踪各项,包括计划起草、窗口界定、发布暂停与通知、幂等写入、回滚策略、对账阈值、审批、切片验证、全窗口对账与证据记录。
限制:资料未提供具体安装命令、支持平台或收费信息;需人工完成计划审批与证据记录,不能替代对账工具本身。