本文介绍了删除celery / rabbitmq中所有待处理的任务的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
如何在不知道每个任务 task_id
的情况下删除所有待处理任务?
How can I delete all pending tasks without knowing the task_id
for each task?
推荐答案
从:
$ celery -A proj purge
或
from proj.celery import app
app.control.purge()
(编辑:使用当前方法更新。)
( Updated with current method.)
这篇关于删除celery / rabbitmq中所有待处理的任务的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!