查找哪个任务进入哪个队列

Question

我正在将 RabbitMQ 与 Celery 一起使用，并且我已经为该任务设置了一些自定义路由设置。一种特定类型的任务进入一个队列，所有其他任务进入另一个队列。现在我想验证它是否有效。

为此，我想检查哪些任务进入了哪个队列。不幸的是，我没有找到任何可以帮助我的东西。 celeryev 监视器仅提供有关已收到哪些任务及其完成状态的信息。 rabbitmqctl 仅向我提供有关当前正在运行和正在等待的任务的信息 - 所以我无法看到我的预期任务转到哪个队列。

有人能帮我解决这个问题吗？

Answer 1

您通常无法使用 AMQP 检查队列上的消息（但不确定 Celery 是否如此）。

如果您只需要将此作为一次性测试，最简单的方法可能是用 Python 编写一个快速程序，从队列中获取所有消息并将其打印出来。

使用py-ampqlib，应该可以做到：

from amqplib import client_0_8 as amqp

conn = amqp.Connection(host="localhost:5672", userid="guest", password="guest", virtual_host="/", insist=False)
chan = conn.channel()

queue_name = "the_queue"

print "Draining", queue_name

while True:
    msg = chan.basic_get(queue_name)
    if msg is None:
        break
    print msg.body

print "All done"

如果您需要更多帮助，这是一个好地方Ask 是 RabbitMQ Discuss 邮件列表。 RabbitMQ 开发人员尽力回答那里发布的所有问题，Celery 的作者也阅读了它。