【发布时间】:2017-07-01 04:50:58
【问题描述】:
我有以下设置:
- RabbitMQ 代理 + Django
- CELERYD_PREFETCH_MULTIPLIER=32 的芹菜(我有很多小任务 因此从性能的角度来看,预取它们很有意义)
- CELERY_ACKS_LATE=False(任务不是幂等的)
我在 docker 容器中运行 celery,所以当我重建 docker celery 时,工作人员不会正常关闭。没关系,如果任务没有得到确认,因为一旦工人在新的 docker 容器中再次启动,经纪人就会将它们发回,但在其他情况下,它们 - 将会丢失。
在花管理面板中预取的任务已收到状态。
我仔细阅读了官方文档和related question,直觉上我觉得我的设置中的预取任务得到了承认。是这样吗?
【问题讨论】:
标签: django rabbitmq celery celery-task