python - 在 Celery 中检索队列中的任务列表

Question

如何检索队列中尚未处理的任务列表？

Answer 1

编辑:查看其他答案以获取队列中的任务列表。

你应该看这里: Celery Guide - Inspecting Workers

基本上是这样的:

my_app = Celery(...)

# Inspect all nodes.
i = my_app.control.inspect()

# Show the items that have an ETA or are scheduled for later processing
i.scheduled()

# Show tasks that are currently active.
i.active()

# Show tasks that have been claimed by workers
i.reserved()

取决于你想要什么