python - 鼠兔将 header 添加到 nack 响应

Question

我正在使用

修改 pika header

properties.headers = {
     'myheader': myheader
}

但我正在使用 delivery_tag

channel.basic_nack(delivery_tag=delivery_tag, requeue=False)

如何将带有 header 的更新属性传递给 ack 和 nack 响应函数？或者鼠兔的做法是什么？

Answer 1

basic_nack 不能更改 header 是正确的。

这样做的方法是根本不使用NACK，而是生成并返回"new"消息(这只是您正在处理的当前消息，但向其中添加了新的 header ) .

根据 AMQP 规范，NACK 基本上是这样做的。

所以我的逻辑是在成功时使用 basic_ack 并在失败时使用更新的 header 生成消息。在我的例子中，我将新消息“重定向”到死信队列绑定(bind)到的死信交换。