Celery:列出所有任务,计划,活动*和*完成

Con*_*ius 22 celery celery-task

更新赏金

如果可能的话,我想要一个不涉及监控线程的解决方案.


我知道我可以使用我的应用程序类查看计划活动任务.InspectControl

i = myapp.control.inspect()

currently_running = i.active()
scheduled = i.scheduled()
Run Code Online (Sandbox Code Playgroud)

但我找不到任何功能来显示已经完成的任务.我知道这些信息至少可以暂时访问,因为我可以通过以下方式查找已完成的任务task_id:

>>> r = my task.AsyncResult(task_id=' ... ')
>>> r.state
u'SUCCESS'
Run Code Online (Sandbox Code Playgroud)

如何获得计划,活动和已完成任务的完整列表?或者可能一次列出所有任务?

mhe*_*her 7

芹菜花实时显示任务(活动,完成,保留等).它可以按时间,工人和类型过滤任务.

https://github.com/mher/flower

  • 我需要在网站中集成监控解决方案,因此不幸的是我无法使用像flower这样的开箱即用的解决方案。但无论如何我都会研究它,因为它支持我的假设,即信息确实是可检索的。所以谢谢你的提示。+1 (3认同)
  • Flower将它们存储在内存中-如果重新启动它,则所有(至少所有完成的)任务都将消失。 (3认同)