使用Python实现清除RabbitMQ里面1小时没有数据的连接
公司RabbitMQ消费者重新连接后旧连接不会断开，会一直存在于服务端，至于是什么原因目前还没有找到。这样导致连接数每过一段时间就增加很多，所以写了一个Python脚本来删除无效的连接，根据每个连接里面的数据传输来定义是否是有效，如果1小时都没有数据传输那么就是无效，具体实现代码如下：1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
#!/usr/bin/python
#coding:utf8
"""
删除RabbitMQ所有在1小时内没有数据的连接
"""
from optparse import OptionParser
import sys
import json
import urllib2
import requests
#使用选项帮助信息可以使用中文
reload(sys)
sys.setdefaultencoding("utf-8")
usage = sys.argv + " <Options>"
parser = OptionParser(usage)
parser.add_option("-v",
dest="vhost",
action="store",
default=False,
help="Select vhost, Defaulte All")
options, args = parser.parse_args()
class RabbitMQ:
def __init__(self, user='guest', passwd='guest', server_ip='192.168.1.31'):
self.user = user
self.password = passwd
self.server_ip = server_ip
def getAllConnections(self):
"""
获取所有连接返回Json
"""
if not options.vhost:
connections = requests.get("http://{0}:15672/api/connections".format(self.server_ip), auth=(self.user, self.password))
else:
connections = requests.get("http://{0}:15672/api/vhosts/{1}/connections".format(self.server_ip, options.vhost),
auth=(self.user, self.password))
connections = connections.json()
return connections
def connectionsNumber(self):
"""
对上面返回的Json进行处理，获取关键数据，返回列表
"""
list1 = []
data = self.getAllConnections()
for i in data:
list1.append(i['name'])
return list1
def url(self):
"""
生成最终访问API,返回列表
"""
url_list = []
data = self.connectionsNumber()
for i in data:
send_ip = i.split("->").split(":")
send_port = i.split("->").split(":").strip()
Receive_ip = i.split("->").split(":").strip()
url = 'http://{0}:15672/api/connections/{1}%3A{2}%20-%3E%20{3}%3A5672?data_rates_age=3600&data_rates_incr=60'.format(self.server_ip, send_ip, send_port, Receive_ip)
url_list.append(url)
return url_list
def getAllData(self):
"""
获取API的所有信息,返回列表
"""
data = self.url()
if self.server_ip == "10.8.5.3":
authorization = "Basic Z3Vlc3Q6UmRuN3lsV2FmZWs2Sjk4aA=="
else:
authorization = "Basic Z3Vlc3Q6Z3Vlc3Q="
user_agent = "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/59.0.3071.115 Safari/537.36"
list1 = []
for i in data:
url = i
request = urllib2.Request(i, headers={"User-Agent":user_agent, "Authorization":authorization})
req = urllib2.urlopen(request)
list1.append(json.loads(req.read()))
return list1
def getAvgRate(self):
"""
获取每个连接的recv_oct_details和send_oct_details，根据1小时平均，如果无数据传输则为无效连接，生成删除API并删除
"""
data = self.getAllData()
for i in data:
n = 2
recv_avg_rate = i.get("recv_oct_details").get("avg_rate")
n += recv_avg_rate
send_avg_rate = i.get("send_oct_details").get("avg_rate")
n += send_avg_rate
if n == 2:
name = i.get("name")
send_ip = name.split("->").split(":")
send_port = name.split("->").split(":").strip()
Receive_ip = name.split("->").split(":").strip()
api = 'http://{0}:15672/api/connections/{1}:{2}%20-%3E%20{3}:5672'.format(self.server_ip, send_ip, send_port, Receive_ip)
code = requests.delete(i, auth=(self.user, self.passwd))
if code.status_code == 204:
print("{0}删除成功".format(send_port))
else:
print("{0}删除失败".format(send_port))
sys.exit(1)
print("done...")
if __name__ == '__main__':
mq = RabbitMQ()
mq.getAvgRate()
页:
[1]