python - 芹菜工人尽管告诉他们不要这样做，但立即接受了 5 份工作

Question

我开始我的芹菜工人

celery -A workerTasks worker --concurrency 1

在 django 的 settings.py 我也有：

CELERYD_PREFETCH_MULTIPLIER = 1
CELERY_worker_prefetch_multiplier = 1

但是一旦连接到 celery 代理，工作人员仍然会消耗 5 个任务。

我错过了什么？

标签： pythoncelery

Answer 1

好的，所以我的错误是我在服务器端而不是工作端设置配置。创建 Celery 应用程序时，我可以像这样显式设置配置：

app = Celery('workerTasks', broker='whatever')


app.conf['worker_prefetch_multiplier'] = 1