在 python 上使用 pika 修改和重新排队消息

Question

我正在使用 Pika/RabbitMQ 库处理 python 3.8 项目中的消息。处理消息时，该功能可能由于多种原因而失败。在某些情况下，消息可以在修改后部分恢复。我目前正在使用修改后的正文创建一条新消息并将其排队。这并不理想，因为处理器是重新排队未发送的消息的处理器。

我想知道是否有办法修改原始消息正文并发送

basic_nack

以便重新排队修改消息以再次处理。这样我就不必重新创建消息代理和消息发送者。

Answer 1

我想知道有没有办法修改原始消息体并发送一个basic_nack以便重新排队修改消息以再次处理

不，任何 AMQP 经纪人都不可能做到这一点。使用修改后的正文创建新消息并发布它是正确的操作。

---

_{注意： RabbitMQ 团队监控}

rabbitmq-users

邮件列表，有时只在 StackOverflow 上回答问题。