Celery：有选择地从 Python 任务中清除队列答案

【问题标题】：Celery: selectively clearing queue from Python tasksCelery：有选择地从 Python 任务中清除队列
【发布时间】：2014-02-06 09:47:08
【问题描述】：

有时我会遇到这样的情况，即 Celery 队列会因意外不必要的任务而增加，从而阻塞服务器。例如。代码执行了 20 000 个任务，而不是 1 个。

如何检查 Celery 队列包含的 Python 任务，然后有选择地摆脱某些任务？

使用标准 Celery 装饰器定义和启动任务（如果重要的话）：

@task()
def update_foobar(foo, bar):
    # Some heavy activon here
    pass

update_foobar.delay(foo, bar)

堆栈：Django + Celery + RabbitMQ。

【问题讨论】：

【解决方案1】：

也许你可以使用Flower。它是 Celery 的实时监视器，具有漂亮的 Web 界面。我认为您可以从那里关闭任务。无论如何，我会尽量避免那些排队的不必要任务。

【讨论】：