python - 如何检查 Celery 中的任务状态？

Question

如何检查一项任务是否在 celery 中运行(具体来说，我使用的是 celery-django)？

我已经阅读了文档，并在谷歌上搜索过，但我没有看到类似的调用:

my_example_task.state() == RUNNING

我的用例是我有一个用于转码的外部 (java) 服务。当我发送要转码的文档时，我想检查运行该服务的任务是否正在运行，如果没有，则(重新)启动它。

我相信我正在使用当前的稳定版本 - 2.4。

Answer 1

返回 task_id(由 .delay() 给出)，然后向 celery 实例询问状态:

x = method.delay(1,2)
print x.task_id

询问时，使用此 task_id 获取新的 AsyncResult:

from celery.result import AsyncResult
res = AsyncResult("your-task-id")
res.ready()