为不同的芹菜 Worker 分配不同的任务-Java 学习之路

我正在使用此命令运行我的服务器：

celery worker -Q q1,q2 -c 2

这表明我的服务器将处理队列 q1 和 q2 上的所有任务，并且我有2名工作人员正在运行 . 我的服务器应支持2个不同的任务：

@celery.task(name='test1')
def test1():
    print "test1"
    time.sleep(3)

@celery.task(name='test2')
def test2():
    print "test2"

如果我将 test1 任务发送到队列 q1 和 test2 到 q2 ，则两个工作人员都将运行这两个任务 . 结果将是：

test1
test2
test1
test2
...

现在我需要的是我的一个 Worker 处理 test1 而另一个处理 test2 . 一个解决方案是运行两个像这样的芹菜 Worker ：

celery worker -Q q1 -c 1
celery worker -Q q2 -c 1

每个人处理1个队列 . 但我想让它们更清洁并使用 -c 2 . 我找到Celery Routing但不确定这是不是我想要的 .

1 回答