异步任务进程退出后消息没消费 队列里的数据去哪了

# 手动确认
msg = channel.basic_get(queue)
try:
    handle(msg)
    channel.basic_ack(msg.delivery_tag)
except Exception:
    channel.basic_nack(msg.delivery_tag, requeue=True)

发布时重启了消费进程，部分订单通知没有发出，队列里也查不到。先别急着动参数，把报错原文和时间点记下来，顺序反了容易白折腾。

原因不复杂，消费时先确认后处理，或使用自动确认模式，进程中断后消息被丢弃。

「异步任务丢失」确认了原因之后，改动尽量只碰那一处，顺手改的东西后面最容易出问题。改动写完就同步给同事，下一个人踩同一个坑，成本还是你的。

验证用真实数据走一遍，测试数据太干净，边界情况根本碰不到。能分两步做的操作就别合成一步，中间看一眼返回值，出问题好判断。

报错里带路径的，先去看那个路径在不在、权限对不对。同一份配置存在多处的，先确认改的是被加载的那一份。

新版本先放一台机器上跑一天再全量，问题一般在这段时间暴露。

处理上按这个顺序：处理成功后再确认；失败进入重试队列；消费端做幂等。

改完只确认一件事：重启演练后消息不丢，重复消费也不会产生重复业务。