在芹菜如何獲得任務狀態爲所有任務的具體任務名稱？

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