转：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 '==============================='

网站栏目：转：MySQL主从、字典死锁、连接数的Python监控脚本-创新互联
URL标题：http://cdiso.cn/article/cscgeg.html