RabbitMQ监视器
jetblack-rabbitmqmon的Python项目详细描述
杰特布莱克拉比特蒙
这是一个异步RabbitMQ监视器API。在
它包装了RabbitMQ管理插件restapi。这允许检索 指标和窥视队列。在
状态
这是一个正在进行的工作，但可以使用。在
安装
这可以与pip一起安装。在
必须选择多个受支持的客户端和一个来。选择以下选项之一：
pip install jetblack-rabbitmqmon[bareclient]
或者选择：
^{pr2}$使用
下面是使用bareclient的概述。在
importasynciofromjetblack_rabbitmqmon.monitorimportMonitorfromjetblack_rabbitmqmon.clients.bareclient_requesterimportBareRequesterasyncdefmain_async():mon=Monitor(BareRequester('http://mq.example.com:15672','admin','admins password'))overview=awaitmon.overview()print(overview)if__name__=='__main__':asyncio.run(main_async())
下面将探讨一个虚拟主机。在
importasynciofromjetblack_rabbitmqmon.monitorimportMonitorfromjetblack_rabbitmqmon.clients.aiohttp_requesterimportAioHttpRequesterasyncdefmain_async():mon=Monitor(AioHttpRequester('http://mq.example.com:15672','admin','admins password'))vhosts=awaitmon.vhosts()forvhostinvhosts.values():# vhost is a dictexchanges=awaitvhost.exchanges()forexchangeinexchanges.values():# exchanges is a dictprint(exchange)# Objects can be refreshed to gather new metrics.awaitexchange.refresh()print(exchange)bindings=awaitexchange.bindings()forbindinginbindings:print(binding)if__name__=='__main__':asyncio.run(main_async())
以下是从交换机获取的一些消息：
importasynciofromjetblack_rabbitmqmon.monitorimportMonitorfromjetblack_rabbitmqmon.clients.bareclient_requesterimportBareRequesterasyncdefmain_async():mon=Monitor(BareRequester('http://mq.example.com:15672','admin','admins password'))vhosts=awaitmon.vhosts()vhost=vhosts['/some-vhost']queues=awaitvhost.queues()queue=queues['some.queue']messages=awaitqueue.get_messages()print(messages)if__name__=='__main__':asyncio.run(main_async())
- 项目
标签：
欢迎加入QQ群-->： 979659372
