向芹菜中的特定消费者发送消息(通过路由密钥)

Question

Celery是否支持专门向特定消费者/客户端发送消息，例如通过路由密钥？

默认情况下RabbitMQ机器可以使用直接队列进行定位，但我正在尝试使用 Celery 实现相同的行为

@app.task
def add(x, y):
return x + y

# something like this
add.delay(1, 2, "machine-xyz")

Answer 1

您可以按-Q worker-abc-queue运行worker-xyz以使其侦听特定队列，然后在调用任务以路由它时指定此队列名称

add.apply_async((1, 2), {}, queue='worker-abc-queue')

Answer 2

另一种方法是在 Celeryapp.task装饰器中设置queue参数，如果不需要以编程方式路由每条消息，这将很方便。

@app.task(queue='YOUR_QUEUE_NAME')
def add(x, y):
return x + y
# so you don't need to specify queue or routing key every time when your code invokes it.
add.delay(1, 2)