所以基本上,我想根据一个特定队列的队列大小/一天中的时间来管理工作人员。我想在高峰时段减少队列中的工作人员数量,并在负载下降时增加工作人员数量。
最佳答案
您可以查看 celery.worker.autoscale
的文档。这允许您设置最小和最大并发度,Celery 将处理工作池。老实说,不能 100% 确定它是如何工作的,但似乎是一个很好的起点。
http://docs.celeryproject.org/en/latest/internals/reference/celery.worker.autoscale.html
关于python - 如何在 celery 中以编程方式添加/删除 worker ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51992766/