python - 如何在 celery 中以编程方式添加/删除 worker ?

标签 python django celery django-celery

所以基本上,我想根据一个特定队列的队列大小/一天中的时间来管理工作人员。我想在高峰时段减少队列中的工作人员数量,并在负载下降时增加工作人员数量。

最佳答案

您可以查看 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/

相关文章:

python - 将 RabbitMQ 与 Plone 一起使用 - 是否使用 Celery?

python - 更改 Ned Batchelder 覆盖率工具的默认 Python 版本

python - 在 SPSS 中转置

django - 属性错误: 'property' object has no attribute 'admin_order_field'

python - 使用 node-celery(MeteorJS) 和 ampq 后端时,Celery 不返回结果

python - 当我将 Django Celery apply_async 与 eta 一起使用时,它会立即完成工作

python - 扩展切片 numpy 数组的步骤

Python-如何在字符串中包含任何随机整数

python - Django - 每个模型 1 个数据库?

android - Android 上的 Django session ID