如何在芹菜中以编程方式添加/删除工人?

Question

所以基本上，我想根据一个特定队列的队列大小/一天中的时间来管理工作线程。我想在高峰时段为队列运行更少的工作器数量，并在负载下降时增加它们。

Answer 1

您可以查看celery.worker.autoscale的文档。这允许您设置最小和最大并发性，Celery 将处理工作线程池。老实说，不是 100% 确定它是如何工作的，但似乎是一个很好的起点。

http://docs.celeryproject.org/en/latest/internals/reference/celery.worker.autoscale.html