2014-11-05 73 views

回答

2

您应该使用terminate杀死已启动的任务。

撤销:

>>> from celery.task.control import revoke 
>>> revoke(task_id) 

当一个人接到一个撤销请求时,它会跳过执行任务,但不会终止已经执行的任务。

终止:

>>> from celery.task.control import revoke 
>>> revoke(task_id, terminate=True) 

如果终止设置工人子进程处理任务将被终止。发送的默认信号是TERM。终止一项任务也会取消它。

必杀:

这是从上述两个不同的。 KILL用于杀死工作人员

ps auxww | grep 'celery worker' | awk '{print $2}' | xargs kill -9 
+0

谢谢您为我清算 – LuckyStrike 2014-11-05 12:59:45