利用Python监测MySQL主从状态

658uhr

  探测MySQL主从状态，如果从未同步，则发邮件通知运维人员。利用定时任务秒级监测！

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49

# -*- coding: utf-8 -* #! /usr/bin/env python from fabric.api import * from fabric.colors import * from fabric.context_managers import * from fabric.contrib.console import confirm import string import smtplib #client ip env.port='9527' env.user='dyt' env.hosts=['192.168.129.138','192.168.129.139'] env.password='dyt2015' #env.mysql_port = '3306' @task def check():     slave_ip  = run("ip add|grep global")     for ip in env.hosts:         if ip in slave_ip:             slave_ip = ip     slave_io  = run("mysql -uroot -S /tmp/mysql_3306.sock -e 'show slave status\G'|grep Slave_IO_Running:|awk '{print $2}'")     slave_sql = run("mysql -uroot -S /tmp/mysql_3306.sock -e 'show slave status\G'|grep Slave_SQL_Running:|awk '{print $2}'")     if slave_io == 'Yes' and slave_sql == 'Yes':         pass     else:         HOST = "smtp.qq.com"     SUBJECT = "MySQL Master-Slave Warning . "     TO = "test@qq.com"     FROM = "test@qq.com"     text = "%-20s MySQL Master-Slave status : down" % slave_ip     BODY = string.join((         "From: %s" % FROM,         "To: %s" % TO,         "Subject: %s" % SUBJECT ,         "",         text         ), "\r\n")     server = smtplib.SMTP()     server.connect(HOST,"25")     server.starttls()     server.login("test@qq.com","password")     server.sendmail(FROM, [TO], BODY)     server.quit()