本文介绍了删除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中所有待处理的任务的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

08-07 05:02