搜索并有选择地从 Celery 中删除任务

Question

我想清理我的芹菜队列。如何按任务的类型参数搜索任务并有选择地删除其中一些任务？如果这很重要，我正在使用 Redis 作为经纪人;不过，我宁愿不在 Redis 级别处理这个问题。

Answer 1

我在这里看到的唯一选择是直接使用 Kombu 库进行编码，这是 Celery 用作 AMQP 的库，该库可以以抽象的方式与所有支持的代理对话，包括 Redis。无论如何，我都会不鼓励这种做法，因为清理队列的需求通常是糟糕设计的结果。

问候