我正在使用celery 3.X和RabbitMQ后端。不时需要重新启动celery(将新的源代码更新推送到服务器)。但是有一个具有大循环和try / catch内部的任务; 它可能需要几个小时才能完成任务。如果我停止它并稍后重新启动它,不会发生任何严重问题。
问题:问题是每次我停止工作进程(通过sudo service celeryd stop),我必须手动KILL该任务(通过kill -9); 该任务忽略来自worker的SIGTERM。 我已经阅读了Celery文档和Stackoverflow,但找不到解决问题的方法。 有什么想法可以解决这个问题吗?
问题:问题是每次我停止工作进程(通过sudo service celeryd stop),我必须手动KILL该任务(通过kill -9); 该任务忽略来自worker的SIGTERM。 我已经阅读了Celery文档和Stackoverflow,但找不到解决问题的方法。 有什么想法可以解决这个问题吗?