用Celery取消已經執行的任務？

Question

我一直在閱讀文檔和搜索，但似乎無法找到一個直接的答案：

你可以取消一個已經執行的任務嗎？ （如任務已經開始，需要一段時間，並且需要取消通過它的一半）

我發現這個從文檔在Celery FAQ

>>> result = add.apply_async(args=[2, 2], countdown=120) 
>>> result.revoke() 

但我不清楚這是否會取消排隊任務或者它是否會殺死一個工作者正在運行的進程。感謝您的任何光線！

Answer 1

撤銷取消任務執行。如果任務被撤銷，工作人員忽略任務並且不執行任務。如果你不使用持久性撤銷，你的任務可以在工人重新啓動後執行。

http://docs.celeryproject.org/en/latest/userguide/workers.html#worker-persistent-revokes

撤銷有一個終止選項，這是假默認。如果您需要終止正在執行的任務，您需要將終止設置爲True。

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

http://docs.celeryproject.org/en/latest/userguide/workers.html#revoke-revoking-tasks

Answer 2

請參閱以下任務的任務：time_limit，soft_time_limit（或者您可以爲工作人員設置）。如果您不想控制執行時間，請參閱apply_async方法的參數expires。

Answer 3

在芹菜3.1中，API of revoking tasks被改變。

按照Celery FAQ，你應該使用result.revoke：

>>> result = add.apply_async(args=[2, 2], countdown=120) 
>>> result.revoke() 

，或者如果你只有任務ID：

>>> from proj.celery import app 
>>> app.control.revoke(task_id) 

Answer 4

@ 0x00mh的答案是正確的，但是最近的芹菜docs說使用terminate選項爲「是管理員的最後一招」，因爲您可能會意外終止在此期間開始執行的其他任務。可能更好的解決方案是將terminate=True與signal='SIGUSR1'（這會導致在任務中引發SoftTimeLimitExceeded異常）相結合。