Python3监控Mysql基于GTID的主从状态

1. 本文使用到的Python模块
   • 使用telnetlib校验服务器是否可被访问
   • 使用SMTP向管理员发送通知邮件
   • 使用MySQL官方的驱动对数据库进行访问
   • 使用optparse实现命令行参数的提取
2. 实现原理
   • 使用optparse模块获取命令行参数。读取defaults-file设置文件内容(如果存在)，使用参数覆盖defaults-file的值（如果传递参数，如：–host, –user, –to之类）。
   • 直接去连MySQL等待是否能进行访问的返回结果太慢了，所以使用telnet对服务器的连通性进行验证。可以设置等待时间，可控性高一些。
   • 当服务器工作正常，使用MySQL与服务器进行连接，获取主从同步的状态。
   • 将获取服务器的异常状态信息（服务器无法访问，主从同步的状态中断），使用SMTP发送给管理员，并把造成中断同步的异常信息一同发送到管理员的邮箱中。

'''
Created on 2016年9月7日

@author: Kael
'''
#coding=utf-8
import pymysql
import telnetlib
import smtplib
from email.mime.text import MIMEText
import optparse
import configparser
import os,time,sys
from pip._vendor.distlib._backport.tarfile import TUREAD

class SlaveStatu:
    __instance__ = None
    __error__ = []

    def __init__(self,*args,**kwargs):
        self.__config__ = {
            "host":"192.168.1.179",
            "user":"root",
            "password":"xxx",
            "port":3306,
            "smtp_host":"smtp.163.com",
            "smtp_user":"xxx@163.com",
            "smtp_password":"xxx",
            "from":"Server<xxx@163.com>",
            "to":"DBA<xxx@163.com>"
        }

        #优先读取设置文件中的值
        if not kwargs["defaults_file"] is None:
            defaults_file = self.__read_defaults_file__( kwargs["defaults_file"] )
            del kwargs["defaults_file"]

        #使用参数的设置去覆盖设置文件的值
        for key,val in kwargs.items():
            if not val is None and len(val) > 0:
                self.__config__[key] = val

    def __configParseMySQL__(self):
        """
        提取数据库的设置
        :return: dict
        """
        return {
            "host"     : self.__config__["host"],
            "port"     : self.__config__["port"],
            "user"     : self.__config__["user"],
            "password" : self.__config__["password"]
        }

    def __configParseSMTP__(self):
        """
        提取SMTP邮件设置
        :return: dict
        """
        return {
            "smtp_host": self.__config__["smtp_host"],
            "smtp_user": self.__config__["smtp_user"],
            "smtp_password": self.__config__["smtp_password"],
            "from": self.__config__["from"],
            "to": self.__config__["to"]
        }

    def __read_defaults_file__( self, filePath ):
        """
        加载设置文件设置的值
        :param filePath: 设置文件路径
        :return:
        """
        section = "config"
        if os.path.exists( filePath ):
            cnf = configparser.ConfigParser()
            cnf.read( filePath )
            options = cnf.options( section )

            for key in options:
                self.__config__[key] = cnf.get( section, key )


    def telnet( self, host, port, timeout=5 ):
        """
        测试服务器地址和端口是否畅通
        :param host: 服务器地址
        :param port: 服务器端口
        :param timeout: 测试超时时间
        :return: Boolean
        """
        try:
            tel = telnetlib.Telnet( host, port, timeout )
            tel.close()
            return True
        except:
            return False

    def connect(self):
        """
        创建数据库链接
        """
        try:
            config = self.__configParseMySQL__()
            if self.telnet( config["host"],config["port"]):
                self.__instance__ = pymysql.connect( **config )
                return True
            else:
                raise Exception("unable connect")
        except:
            self.__error__.append( "无法连接服务器主机: {host}:{port}".format( host=config[
                    "host"], port=config["port"]) )
            return False

    def isSlave(self):
        """
        数据库同步是否正常
        :return: None同步未开启,False同步中断,True同步正常
        """
        cur = self.__instance__.cursor()
        sql = "show slave status"
        cur.execute(sql)
        result = cur.fetchone()
        print(result)
        cur.close()

        if result:
            print(result[10])
            print(result[11])
            if result[10] == 'Yes' and result[11] == 'Yes':
                return True
            else:
                if result[10] == 'No':
                    self.__error__.append( result[35] )
                else:
                    self.__error__.append( result[37] )
                return False

    def get_last_error(self):
        """
        获取第一个错误信息
        :return: String
        """
        if self.__error__:
            return self.__error__.pop(0)

    def notify(self,title,message):
        """
        发送消息提醒
        :param title: 消息的标题
        :param message: 消息的内容
        :return:
        """
        msg    = [title,message]
        pool   = []
        notify = notify_email( self.__configParseSMTP__() )
        pool.append( notify )

        for item in pool:
            item.ring( msg )

    def close(self):
        """
        关闭数据库链接
        """
        if self.__instance__:
            self.__instance__.close()

class notify_email(object):
    def __init__(self,config):
        self.config = config

    def ring(self, message=[]):
        subject = message.pop(0)
        messageBody = "".join( message )
        mailList = self.config["to"].split(";")
        datetime = time.strftime("%Y-%m-%d %H:%M:%S")
        for to in mailList:
            body = """
            <p>管理员<strong>{admin}</strong>，你好:</p>
            <p style="text-indent:2em;">收到这封邮件说明你的数据库同步出现异常，请您及时进行处理。</p>
            <p>异常信息：<br />{body}</p>
            <p style="text-align:right;">{date}</p>
            """.format( admin=to, body=messageBody, date=datetime )

            msg            = MIMEText( body, "html", "utf-8" )
            msg["From"]    = self.config["from"]
            msg["To"]      = to
            msg["Subject"] = subject
            smtp           = smtplib.SMTP()

            smtp.connect( self.config["smtp_host"],"25" )
            if "smtp_host" in self.config:
                smtp.login( self.config["smtp_user"], self.config["smtp_password"] )  
            smtp.sendmail( self.config["from"], to, msg.as_string() )
            smtp.quit()

if __name__ == "__main__":
    #命令行参数列表
    usage = """usage: MySQLStat [options]"""

    opt = optparse.OptionParser(usage=usage)
    opt.add_option("-H","--host",dest="host",help="MySQL host (default: localhost)")
    opt.add_option("-u","--user",dest="user",help="MySQL user")
    opt.add_option("-p","--password",dest="password",help="MySQL password")
    opt.add_option("-P","--port",dest="port",help="MySQL port (default: 3306)")
    opt.add_option("","--smtp_host",dest="smtp_host",help="SMTP host (default: localhost)")
    opt.add_option("","--smtp_user",dest="smtp_user",help="SMTP user")
    opt.add_option("","--smtp_password",dest="smtp_password",help="SMTP password")
    opt.add_option("","--from",dest="from",help="Email from")
    opt.add_option("","--to",dest="to",help="Email to")
    opt.add_option("","--defaults-file",dest="defaults_file",help="config file path")
    (options,args) = opt.parse_args()

    options = options.__dict__
    Statu = SlaveStatu( **options )
    subject = "您好，您的主从服务出现故障，请及时查看"
    if Statu.connect() is False or Statu.isSlave() is False:
        Statu.notify( subject, Statu.get_last_error() )
    Statu.close()

创建default.cnf

[config]
smtp_host=smtp.163.com
smtp_user=xxx@163.com
smtp_password=xxx
from=Server<xxx@163.com>
to=DBA<xxx@163.com>
host=192.168.1.179
user=root
password=xxx

开启定时任务监控主从

crontab 
*/2 * * * * python slavecheckpoint.py --defaults-file=default.cnf --to=xxx@163.com