批量改商品触发大量 webhook 把服务打挂怎么办

现象#

一次 CSV 导入后几分钟内收到上万条 products/update，队列堆积，下游接口被限流。

原因#

• 批量操作逐个触发事件，没有合并
• 消费者同步调用 Admin API，进一步放大压力
• 没有去重与节流

处理步骤#

1. 消费端按资源 ID 做窗口去重（如 30 秒内同一 ID 只处理一次）
2. 改为「标记脏数据 + 定时批量拉取」，而不是逐条处理
3. 队列设置并发上限与退避，避免打爆下游
4. 大批量导入前临时降级非关键处理逻辑

验收标准#

批量导入期间队列不堆积到不可控，最终数据一致，关键业务未被拖垮。