如何从不同应用程序的芹菜队列中消费

Question

我的生产者应用程序中有以下代码，用于使用 Celery 将 API 调用插入到我的 RabbitMQ 中。

celery.send_task('tasks.process_redox', (payload,), queue="redox_inbound")

我想知道，从该队列中使用代码会是什么样子？我有下面的，但它不起作用，似乎无法在

中找到它

@celery.task()
def process_redox(payload):
  data = encrypter.decrypt(payload)
  print data
  return

Answer 1

你需要告诉芹菜看那个队列。

app.conf.task_queues = (
    Queue('redox_inbound',    routing_key='default'),
)

How to consumer from a celery queue in a different app