如何使用 python 列出或发现 RabbitMQ 交换上的队列？

Question

我需要一个 python 客户端，它可以在重新启动的 RabbitMQ 服务器交换上发现队列，然后启动客户端以恢复使用每个队列中的消息。如何从一些与 RabbitMQ 兼容的 python api/库中发现队列？

Answer 1

由于我是 RabbitMQ 初学者，所以对此持保留态度，但有一个有趣的 管理插件，它公开了一个 HTTP 接口，“从这里您可以管理交换、队列、绑定、虚拟主机、用户和权限。这是相当不言自明的。”

http://www.rabbitmq.com/blog /2010/09/07/management-plugin-preview-release/

Answer 2

我使用 https://github.com/bkjones/pyrabbit。它直接与 RabbitMQ 的 mgmt 插件的 API 接口对话，并且对于询问 RabbitMQ 非常方便。

Answer 3

管理功能将在 AMQP 的未来版本中提供。因此，现在您必须等待具有该功能的新版本。

Answer 4

我发现这对我有用，/els 是我的演示虚拟主机名..

rabbitmqctl list_queues --vhost /els

Answer 5

Pyrabbit 对我来说效果不太好；但是，管理插件本身有自己的命令行脚本，您可以从自己的管理 GUI 下载该脚本并稍后使用（例如，我从其中下载了我的脚本

http://localhost:15672/cli/

以供本地使用）

Answer 6

我会简单地使用这个：
只需将 user(default= guest)、passwd(default= guest) 和 port 替换为您的值即可。

import requests
import json

def call_rabbitmq_api(host, port, user, passwd):
  url = 'http://%s:%s/api/queues' % (host, port)
  r = requests.get(url, auth=(user,passwd))
  return r

def get_queue_name(json_list):
  res = []
  for json in json_list:
    res.append(json["name"])
  return res

if __name__ == '__main__':
  host = 'rabbitmq_host'
  port = 55672
  user = 'guest'
  passwd = 'guest'
  res = call_rabbitmq_api(host, port, user, passwd)
  print ("--- dump json ---")
  print (json.dumps(res.json(), indent=4))
  print ("--- get queue name ---")
  q_name = get_queue_name(res.json())
  print (q_name)

从这里引用： https://gist.github.com/hiroakis/ 5088513#file-example_rabbitmq_api-py-L2

Answer 7

似乎没有直接的 AMQP 方式来管理服务器，但有一种方法可以通过 Python 来实现。我建议结合使用 subprocess 模块和 rabbitmqctl 命令来检查队列的状态。

我假设您在 Linux 上运行它。从命令行运行：

rabbitmqctl list_queues

将导致：（

Listing queues ...
pings   0
receptions      0
shoveled        0
test1   55199
...done.

好吧，由于我的特定队列，在我的情况下确实如此）

在您的代码中，使用此代码获取rabbitmqctl的输出：

import subprocess

proc = subprocess.Popen("/usr/sbin/rabbitmqctl list_queues", shell=True, stdout=subprocess.PIPE)
stdout_value = proc.communicate()[0]
print stdout_value

然后，只需出现使用您自己的代码来解析 stdout_value 供您自己使用。

Answer 8

你可以添加插件rabbitmq_management

sudo /usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management
sudo service rabbitmq-server restart

然后使用rest-api

import requests

def rest_queue_list(user='guest', password='guest', host='localhost', port=15672, virtual_host=None):
    url = 'http://%s:%s/api/queues/%s' % (host, port, virtual_host or '')
    response = requests.get(url, auth=(user, password))
    queues = [q['name'] for q in response.json()]
    return queues

我在这个例子中使用requests库，但它并不重要。

我还找到了为我们做这件事的库 - pyrabbit

from pyrabbit.api import Client
cl = Client('localhost:15672', 'guest', 'guest')
queues = [q['name'] for q in cl.get_queues()]

Answer 9

据我所知，没有任何办法可以做到这一点。这与 Python 无关，而是因为 AMQP 没有定义任何队列发现方法。

无论如何，在 AMQP 中，是客户端（消费者）声明队列：发布者使用路由键将消息发布到交换器，消费者确定这些路由键进入哪些队列。所以在没有消费者的情况下谈论队列是没有意义的。