我经常使用延迟任务,所以在RabbitMQ队列中有大约6000个任务。当芹菜工作进程在调试日志中重新启动时,出现约6000个条目:
INFO/MainProcess] Received task: celery.task_name
[4026841c-1d3a-4097-9e43-39b0b81b7b23] eta:[2016-08-11 10:54:16.179000+03:00]由于注册任务的数量很大,芹菜工人无法处理延迟约10-15分钟的新实时任务。当前芹菜重新启动时间)。
如何加快重启过程?
发布于 2017-02-28 23:52:54
将--purge添加到您的重新启动命令中,以首先清除队列
https://stackoverflow.com/questions/38871622
复制相似问题