如何从 celery 任务队列中删除任务？

Question

如何在任务结束后立即删除队列中的所有任务？

我想要这样的东西 (Deleting all pending tasks in celery / rabbitmq) 但对于 celery 3.0.

谢谢

编辑：

来自 celery 文档： http://docs.celeryproject.org/en/latest/faq.html#how-do-i-purge-all-waiting-tasks

我的代码如下：

从 celery 导入 current_app 作为 celery

@task
def task_a():
    celery.control.purge()

我期待，如果我发出 5 个任务，那么只有第一个会运行。不知何故，我不这样做。

谢谢

Answer 1

这些任务可能已经被工作人员预取。要确定是这样，请尝试运行的任务数量超过活动工作人员乘以预取乘数（见下文），并检查celery.control.purge() 返回的结果。您可以使用配置参数CELERYD_PREFETCH_MULTIPLIER 和CELERY_ACKS_LATE 控制预取任务的数量。