最近,公司的系统在天津增加了不少异地容灾,其中就有异地双主 MySQL。由于容灾环境一般只会在出现较大的网络故障或故障演习的时候用到,所以,容灾系统的可用性就只能靠监控了。
对于互联网这种赶鸭式的发展模式,很多公司都没有完善的自动化运维系统。所以,很多时候还得靠自己写脚本。
脚本越写越多,就容易出现混乱、分散难管理的窘状。所以,这次就写了一个 MySQL 的集中监控脚本,后续有新的监控加入也可以非常方便的拓展。
Python 脚本:
#!/usr/bin/python # MySQL 主从集中监控脚本 # 请在 MySQL 上执行如下语句,将跑脚本的机器授权一个 db_monitor 账号。 # grant SHOW VIEW,REPLICATION CLIENT,SHOW DATABASES,PROCESS on *.* to db_monitor@'192.168.1.10'; import MySQLdb import os import datetime # 发送一个字符串告警,公司特有告警系统,可以改成其他监控方式,比如短信或邮件 def report_alarm(attr, err_msg): os.system('/usr/local/agenttools/agent/agentRepStr %s "%s" >/dev/null' % (attr, err_msg)) # 上报一个数值型告警,也是特有告警系统 def send_repnum(attr, num): os.system('/usr/local/agenttools/agent/agentRepNum %s "%s" >/dev/null' % (attr ,num) ) def monitor(db_host): try: cxn=MySQLdb.connect(db_host, 'db_monitor', '', db='mysql') except MySQLdb.Error, e: try: sqlError = "Error %d:%s" % (e.args[0], e.args[1]) except IndexError: sqlError = "MySQL Error:%s" % str(e) report_alarm(36320, sqlError) #get mysql version cur=cxn.cursor() cur.execute('select version()') for item in cur.fetchall(): if '5.0.' in item[0]: mysql_version = 'low' else: mysql_version = 'high' #show slave status cur=cxn.cursor() cur.execute('show slave status') for item in cur.fetchall(): replicate_error = item[19] if mysql_version == 'low': seconds_behind_master = item[-1] else: seconds_behind_master = item[32] #show processlist cur=cxn.cursor() cur.execute('show processlist') connect_num = len(cur.fetchall()) meta_lock_num = cur.fetchall().count("meta lock") cxn.close() return replicate_error,seconds_behind_master,connect_num,meta_lock_num print datetime.datetime.now() for host in open('%s/hosts.list'% os.path.dirname(os.path.realpath(__file__))): host = host.strip('\n') replicate_error = '' seconds_behind_master = 0 connect_num = 0 meta_lock_num = 0 replicate_error,seconds_behind_master,connect_num,meta_lock_num = monitor(host) try: Seconds_behind_master = int(seconds_behind_master) except: Seconds_behind_master = seconds_behind_master print '===============================' print 'Infomation of %s' % host print "The Num of metalock : %s" % meta_lock_num print "The Num of connection : %s" % connect_num # 上报当前连接数 send = send_repnum(36713, connect_num) # 上报字典锁数量 send = send_repnum(36715, meta_lock_num) if len(replicate_error) > 0: print replicate_error # 如果主从同步出现问题,就发送告警 report_alarm(36320, '%s: Replicate error' % host) elif Seconds_behind_master > 600: print "Seconds behid master: %s" % Seconds_behind_master # 如果主从延迟超过 600s,就发送告警 report_alarm(36320, '%s: Seconds behind master ge 600' % host) #else: # print host + " is OK!" print '==============================='
用法很简单,只要在脚本同目录新增一个文本文件 hosts.list,一行一个 IP,然后需要在 IP 对应的 MySQL 身上新增一个 db_monitor 账号,用于监控机远程登录 MySQL(见脚本注释部分语句):
其他特性:
①、脚本支持 5.0 和 5.5+ MySQL 版本的 Second behid master 监控,因为新老版本这个参数的位置不一样(鹅厂很多开源软件是非常陈旧的。。。);
②、支持 MySQL 连接失败的监控;
③、支持 MySQL 主从复制的延迟和错误监控
④、支持 MySQL 的连接数和字典锁数监控
⑤、更多监控可以参考继续添加.....
好了,就这么多了,算是给自己一个备忘。
签到成功!签到时间:下午3:04:55,每日签到,生活更精彩哦~
太深奥的内容,看不懂。
:roll: 我也是一点都看不懂!
这个不是懂技术的,或者程序员是理解的吧
技术男出文章有质量!!
不错的文章 。。。。。
。。。。。。。。学习了
技术贴,小白路过
看着很迷糊 不是很懂
:lol: 你比我厉害多了,我是完全看不懂!
看懂一些
确实简单易懂 , mysql 主从复制 one master and more slave
我的博客 奉化人才网 http://www.fenghuarc.com 是否换个连接
我的博客 奉化人才网 http://www.fenghuarc.com 是否换个连接
1是不相关,2你的站是新站,也不符合要求。
:sad: 偶也表示完全不懂这些!
内容很丰富,学习了!!!
谢谢分享经验
张大神,文章越来越深澳了,多来点wp技术文章
多来点wp技术文章, :wink: 跟我的想法完全一样!
签到成功!签到时间:下午2:36:38,每日签到,生活更精彩哦~
这么多内容,就看懂了一个主从。。。
这位先森你好!我也姓成,好巧呀!
看不懂
不错,很好,正需要这个
看来不止我一个人没看懂哦。。
签到成功!签到时间:下午7:46:33,每日签到,生活更精彩哦~
不错呦,可以拿过来按照自己的工作需求加以修改直接用,省事儿!