在芹菜如何获得任务状态为所有任务的具体任务名称？

Question

在celery我想获取特定任务名称的所有任务的任务状态。为此尝试下面的代码。

import celery.events.state 

# Celery status instance. 
stat = celery.events.state.State() 

# task_by_type will return list of tasks. 
query = stat.tasks_by_type("my_task_name") 

# Print tasks. 
print query 

现在我在这段代码中得到空列表。

Answer 1

这不是本机支持的。根据后端（Mongo，Redis等）的不同，您可能会也可能不会反思队列中的内容并找出其中的内容。即使你这样做，你也会错过当前正在进行的项目。

这就是说，你可以管理这个自己：

result = mytask.delay(...) 
my_datastore.save("mytask", result.id) 
... 
for id in my_datastore.find(task="mytask"): 
    res = AsyncResult(id) 
    print res.state