我正在使用 Pika/RabbitMQ 库处理 python 3.8 项目中的消息。处理消息时,该功能可能由于多种原因而失败。在某些情况下,消息可以在修改后部分恢复。我目前正在使用修改后的正文创建一条新消息并将其排队。这并不理想,因为处理器是重新排队未发送的消息的处理器。
我想知道是否有办法修改原始消息正文并发送
basic_nack
以便重新排队修改消息以再次处理。这样我就不必重新创建消息代理和消息发送者。
我想知道有没有办法修改原始消息体并发送一个basic_nack以便重新排队修改消息以再次处理
不,任何 AMQP 经纪人都不可能做到这一点。使用修改后的正文创建新消息并发布它是正确的操作。
注意: RabbitMQ 团队监控
rabbitmq-users
邮件列表,有时只在 StackOverflow 上回答问题。