使用Python实现清除RabbitMQ里面1小时没有数据的连接
公司RabbitMQ消费者重新连接后旧连接不会断开,会一直存在于服务端,至于是什么原因目前还没有找到。这样导致连接数每过一段时间就增加很多,所以写了一个Python脚本来删除无效的连接,根据每个连接里面的数据传输来定义是否是有效,如果1小时都没有数据传输那么就是无效,具体实现代码如下:
#!/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[0] + " <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("->")[0].split(":")[0] send_port = i.split("->")[0].split(":")[1].strip() Receive_ip = i.split("->")[1].split(":")[0].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("->")[0].split(":")[0] send_port = name.split("->")[0].split(":")[1].strip() Receive_ip = name.split("->")[1].split(":")[0].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()
![](/img/my/wx.png)
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
shell脚本执行超时怎么办?
在shell里会有一种不太常见的情况,就是脚本有时候会出现超时的现象。一般来说遇到这种问题,我们都会简单粗暴的采用下面这种脚本来当“超时看门狗“: #!/bin/bash ./$1&#这里设定后台运行的第一个参数 pid=$!#最后一个运行的process的PID值 sleep$2&&kill-9$pid&#如果超过了$2的值的话,就会把那个PID干掉 这个脚本搭配两个变量使用的话,监控一点小代码还算OK,但是它的逻辑还是比较粗糙,比如如果在这个脚本执行的时候,又有了一个新的process在后台启动,那么kill掉的就是新的process,而本应该停止的脚本还是在后台肆无忌惮的跑着。 为了不滥杀无辜,所以遇到这种情况,就要使用timeout命令,具体的用法请自行#man timeout,这个命令在centos 6里就是自带的。 假设我们要ping www.baidu.com ,同时要求“若超过了5秒没有反应,就停止这个任务”。那么就是用命令:#timeout5spingwww.baidu.com,效果如图: 从26秒到31秒,的确达到了5秒就跳出的效果。...
- 下一篇
SQL优化之基于SQL特征的改写
前言 今天老K继续与大家分享第九期。 周末老K宅在家观战了两局精彩的“人狗”大战。老K既算不上科技迷,也算不上围棋迷,不过对此颇有感触:阿尔法狗不过是通过左右互博的方式不断学习围棋,然而依赖其最优的学习算法(学习方法)却能再短短的数月之内达到人类围棋水平的最顶端;而李世石在却是依赖其已有的经验结合人类特有的灵感下出“神之一手”,人类终究还是可以战胜拥有超强计算能力的阿尔法狗。这些不禁让老K想起了自己在工作过程中的最有艺术性的部分---“SQL tunning”,一方面要不断学习积累运用不同的优化方法,同时在必要时多一分想象力和灵感,这样面对不同的SQL问题,我们才能下出自己的“神之一手”。 好了,今天老K与大家分享的案例是SQL调优的案例,但老K更希望大家能从中体会到SQL tunning过程中的优化方法和思维方式,真正做到它山之石,可以攻玉。同时,大家如果觉得老K的方法还不错,不妨轻轻的转发一下,分享给身边更多的ORACLE技术爱好者。 今天分析的问题是客户DBA给过来的一条SQL语句,已经困扰其一段时间了,希望老K一起来分析解决。解决这个问题对老K来说并不是特别难,不过在这个问题的...
相关文章
文章评论
共有0条评论来说两句吧...