6

我正在使用芹菜来处理一些任务。我可以看到有多少活动或计划等，但我无法找到任何方法来查看失败的任务。Flower 确实向我显示了状态，但前提是它在任务启动和失败时正在运行。是否有任何命令可以获取所有失败的任务（状态：失败）？

创建任务时我确实有任务ID。但是有数以百万计的。所以即使有办法通过任务ID检查，我也无法一一检查。但是如果有这样的命令，请告诉我。

4

2 回答 2

9

Celery 并不容易找到失败的任务，但Flower（主要的 Celery 管理网络应用程序）确实简化了这一点。即使在任务完成后，它也会记录任务 ID，并有一个 API 让您只查找失败的任务。

Flower 相当基本的 HTTP API 包括/api/tasks 端点——您可以使用它 /api/tasks?state=FAILURE来仅显示失败的任务，然后解析 JSON 以提取您需要的内容。内容类似于您在 Web API 中获得的内容，并且很容易使用jqcurl进行原型制作和格式化/过滤：

curl -s 'http://localhost:5555/api/tasks?state=FAILURE&limit=5' | jq . | less

Flower 当然需要安装和运行。

由于您有数百万个已完成的任务，您可能需要在数据存储中捕获失败的任务信息以进行有效访问 - 也许 Flower 会有所帮助。或者您可以在 Celery 中尝试自定义故障处理程序，以捕获刚刚失败的任务信息 - 请参阅此答案。

于 2015-09-30T06:47:01.063 回答
3

task id有state和status属性。所以你可以通过id获取任务的状态。

my_task_id = my_task.delay(foo)
my_task_id.state
my_task_id.status

给出状态是 PENDING、STARTED、RETRY、FAILURE 还是 SUCCESS。

afaik，celery 只显示活动、计划、保留、撤销，但 id 不显示失败的任务。

由于您拥有所有任务 ID，因此您可以遍历它们的状态。

for task_id in task_id_list:
    if task_id.state == 'FAILURE'
        print(task_id)
于 2014-10-29T12:25:59.207 回答