将不同的任务分配给不同的芹菜工人答案

【问题标题】：Assign different tasks to different celery workers将不同的任务分配给不同的芹菜工人
【发布时间】：2013-11-09 08:02:11
【问题描述】：

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

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
...

现在我需要的是我的一名工人处理test1，另一名处理test2。一种解决方案是像这样运行两个 celery worker：

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

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

【问题讨论】：

【解决方案1】：

我找到了答案，我把它放在这里以防其他人也想这样做：

可以使用celery multi 代替celery worker -Q q1,q2 -c 2：

celery multi start 2 -Q:1 q1 -Q:2 q2 -c:1 1 -c:2 1

这表示我们有 2 个队列：-Q:1 q1 表示队列 #1，名称为 q1，q2 相同，每个队列都有不同的并发，-c:1 1 表示第一个 celery worker 具有并发1 个。

【讨论】：