【发布时间】:2016-02-24 13:23:47
【问题描述】:
我想启动一系列 Celery 任务,并让它们在任何新到达的任务之前全部执行。我将有一个工作进程来处理所有任务。
我想最简单的做法是根本不让它们成为链,而是启动一个同步调用一系列函数的任务。但我想利用 Celery 重试,允许每个任务重试不同的次数。
最好的方法是什么?
【问题讨论】:
标签: celery
我想启动一系列 Celery 任务,并让它们在任何新到达的任务之前全部执行。我将有一个工作进程来处理所有任务。
我想最简单的做法是根本不让它们成为链,而是启动一个同步调用一系列函数的任务。但我想利用 Celery 重试,允许每个任务重试不同的次数。
最好的方法是什么?
【问题讨论】:
标签: celery
如果你有一个工作人员运行一个进程,那么据我所知,使用 celery(这没有明确记录)你应该得到你想要的行为。
如果您想使用多个工作进程,则可能需要将CELERYD_PREFETCH_MULTIPLIER 设置为 1。
【讨论】:
CELERYD_PREFETCH_MULTIPLIER 设置为什么?