python - 如何按任务名称检查和取消 Celery 任务

Question

我使用 Celery (3.0.15) 和 Redis 作为代理。

是否有一种直接的方法可以查询 Celery 队列中存在的具有给定名称的任务的数量？

作为后续，有没有办法取消 Celery 队列中存在的所有具有给定名称的任务？

我已经通过Monitoring and Management Guide并且在那里看不到解决方案。

Answer 1

# Retrieve tasks
# Reference: http://docs.celeryproject.org/en/latest/reference/celery.events.state.html
query = celery.events.state.tasks_by_type(your_task_name)

# Kill tasks
# Reference: http://docs.celeryproject.org/en/latest/userguide/workers.html#revoking-tasks
for uuid, task in query:
    celery.control.revoke(uuid, terminate=True)