与多个经纪人一起开始芹菜工人

Question

目前，我有一个 celery.py 和一个 redis 代理

proj/celery.py

from __future__ import absolute_import

from kombu import Exchange, Queue
from celery import Celery

app = Celery('proj',
             broker='redis://myredis.com'
             backend='redis://myredis.com'
             include=['proj.tasks])

if __name__ == '__main__':
    app.start()

我会开始一个工人：

celery multi start somename -A proj -Q work -c20 --pidfile='somepidfile' --logfile='somelogfile'

在多台机器上（比如说 20..）

所以这些跨 20 台机器的工作人员使用一个代理，

'redis://myredis.com'

我想将其拆分，以便 10 台机器使用 'redis://myredis.com'，其他 10 台机器使用 'redis://myredis2.com'

我需要做哪些改变才能做到这一点？

谢谢

Answer 1

一个简单的方法是让 DNS 以循环方式解析为 redis://myredis.com 和 redis://myredis2.com。如果您有足够的工人，这应该大致平均分配 2 个经纪人。