芹菜工人失败任务要求逻辑(RabbitMQ)



我有以下设置:

celery version = 4.2.1
task_reject_on_worker_lost = True
task_acks_late = True

我试图收到一条消息,最初是通往" queuea"的路由,如果正在处理的芹菜工人突然失败了,我希望该消息将新的队列重新添加到新的队列" queueb"。是否可以通过对我的RabbitMQ队列设置进行调整或通过芹菜进行调整?

我已经有一个已正确配置为queuea的死信交易所,该交换处理了TTL的处理此类路由(即消息转到Queuea坐在Queuea坐着直到TTL,然后转到Dead Letter排队并最终返回QueueB)。

来自rabbitmq邮件列表

在通道上(以及连接)闭合在同一队列1上始终发生自动申请。 这种情况不会导致死亡的刻字,任何DLX设置都不会产生任何效果。 在3.8的法定人数中,自动申请有时可能会导致死亡字母,因为有一个可选的 重新传递计数限制。那将与您想要的东西接近。由于Quorum队列不是RabbitMQ 3.7中可用的功能,因此此功能也不是。 3.8.0目前在beta.3 [2],并将在2019年中期发货。 1. https://www.rabbitmq.com/confirms.html 2. https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.8.0-beta.3 在此处记录了重新传递限制(https://next.rabbitmq.com/quorum-queues.html)

相关内容

  • 没有找到相关文章

最新更新