| 123456789101112131415161718192021222324252627 |
- # -*- coding: utf-8 -*-
- # @Time : 2023/1/3 10:47
- # @Author : XuJiakai
- # @File : rabbit_mq_info
- # @Software: PyCharm
- import requests as r
- from utils.base_utils import map_2_json_str
- rabbit_mq_host = 'http://106.15.78.184:15672'
- username = 'whc'
- pwd = 'whc'
- def get_all_queue_info(host: str = rabbit_mq_host, username: str = username, pwd: str = pwd):
- res = r.get(host + '/api/queues', auth=(username, pwd))
- data = res.json()
- all_info = {}
- for i in data:
- all_info[i['name']] = i['messages']
- return all_info
- if __name__ == '__main__':
- result_data = get_all_queue_info(rabbit_mq_host, username, pwd)
- print(map_2_json_str(result_data))
- pass
|
