最近，公司的系统在天津增加了不少异地容灾，其中就有异地双主MySQL。由于容灾环境一般只会在出现较大的网络故障或故障演习的时候用到，所以，容灾系统的可用性就只能靠监控了。

<p>对于互联网这种赶鸭式的发展模式，很多公司都没有完善的自动化运维系统。所以，很多时候还得靠自己写脚本。

<p>脚本越写越多，就容易出现混乱、分散难管理的窘状。所以，这次就写了一个MySQL的集中监控脚本，后续有新的监控加入也可以非常方便的拓展。
用法很简单，只要在脚本同目录新增一个文本文件hosts.list，一行一个IP，然后需要在IP对应的MySQL身上新增一个 db_monitor账号，用于监控机远程登录MySQL（见脚本注释部分语句）

>其他特性：
	<p>①、脚本支持 5.0 和 5.5+ MySQL版本的 Second behid master 监控，因为新老版本这个参数的位置不一样（鹅厂很多开源软件是非常陈旧的。。。）；
	<p>②、支持MySQL连接失败的监控；
	<p>③、支持MySQL主从复制的延迟和错误监控
	<p>④、支持MySQL的连接数和字典锁数监控
	<p>⑤、更多监控可以参考继续添加.....

	#!/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 '==============================='

ITPub博客

转：MySQL主从、字典死锁、连接数的Python监控脚本

最新文章