我将celeryd作为守护进程运行,但有时很难优雅地停止它。当我发送术语信号并且队列中有条目(在本例中为service celeryd stop)时,celeryd将停止接收新作业,并关闭所有工作进程。但是,父进程不会关闭。
我刚刚遇到了这样一个场景,我让celeryd在两台独立的工作机器上运行:A和B。在RabbitMQ服务器上有大约1000条消息时,我关闭了A,并经历了我在上面解释过的情况。B继续工作,但随后在服务器上留下了大约40条消息而停止。然而,我能够正确地阻止B。
我重新启动了B,看看它是否会将40个条目从队列中移除,但它不会。接下来,我硬杀了A,之后B抓取并完成了任务。
我的结论是父进程已经从我们的RabbitMQ服务器中为其子进程保留了40个条目。它将正确地收获子对象,但不会将物品释放回RabbitMQ,除非我手动杀死它。
有没有人经历过类似的事情?
我运行的是Celery 2.2.2
发布于 2011-03-24 00:51:17
我相信这与以下情况有关:
https://github.com/celery/celery/issues/264
设置
CELERY_DISABLE_RATE_LIMITS = False在您的settings.py文件中应该可以工作。
https://stackoverflow.com/questions/5045687
复制相似问题