我开始我的 celery worker
celery -A workerTasks worker --concurrency 1
在 django 的 settings.py 中我还有:
CELERYD_PREFETCH_MULTIPLIER = 1
CELERY_worker_prefetch_multiplier = 1
但是工作人员在连接到 celery 代理后仍然会消耗 5 个任务。
我错过了什么？
最佳答案
好吧，所以我的错误是我在服务器端而不是工作端设置配置。创建 Celery 应用程序时，我可以像这样显式设置配置:
app = Celery('workerTasks', broker='whatever')
app.conf['worker_prefetch_multiplier'] = 1
关于python - celery worker 尽管告诉他们不要这样做，但仍立即接受了 5 份工作，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56987063/