我想根据Celery和Redis用我的Django应用程序提出一个问题。正如我将进一步详细解释,我对这些应用程序有一些随机问题。
我的环境:
我……
如果您愿意,您似乎有待处理的任务 清除待处理的任务
你可以做到
from main.celery import app app.control.purge()
或者你可以做 celery -A main purge
celery -A main purge
如果要丢弃特定队列的任务,则可以执行此操作
celery amqp queue.purge <queue name>