python - 如何以编程方式从 Celery 队列中提取项目？

Question

我有一个 Celery 队列，我想根据某些触发器等以编程方式从队列中提取下一个项目。

如果我有一个任务定义为

@task
def my_task():
    do_stuff()

然后通过将项目放入队列

my_task.apply_async()

Celery 将尽快处理队列中的项目。但我希望能够做的是这样的:

my_task.process_next()

有什么方法可以控制 Celery 何时从队列中提取内容？

Answer 1

Celery 非常合理地假设，一旦有东西进入队列，您就希望它尽快得到处理。 there is the countdown argument但我想这不是你想要的。

您可以尝试覆盖 Task Class并将一些逻辑放入__call__中方法来检查您是否确实想要处理该任务，然后如果发现它尚未准备好按您的计划进行处理，则可以安排它重试。