1. #!/usr/bin/env python
    2. # -*- coding: UTF-8 -*-
    3. #脚本需要和 pt-table-checksum一起使用
    4. #通过监控pt-table-checksum生产的checksums表来确认表是否一致
    5. #脚本要在主库执行
    7. import smtplib
    8. from email.mime.text import MIMEText
    9. import time,datetime
    10. import os,sys
    11. import MySQLdb as mdb
    13. mail_host = ''
    14. mail_user = ''
    15. mail_postfix = ''
    19. def check_info():
    20.     try:
    21.         #这里要连接从库
    22.         con = mdb.connect(host='',user='',passwd='',db='test',port=3306)
    23.         cur = con.cursor()
    24.         sql = "select * from checksums where this_crc not in (select master_crc from checksums  )"
    25.         cur.execute(sql)
    26.         res = cur.fetchall()
    27.         con.close()
    28.         return res
    29.     except Exception,e:
    30.         print e
    32. def send_mail(mail_to,subject,content):
    33.     me = mail_user+"<"+mail_user+"@"+mail_postfix+">"
    34.     msg = MIMEText(content,'html','utf-8')
    35.     msg["subject"] = subject
    36.     msg["From"] = me
    37.     global sendstatus
    38.     global senderr
    40.     try:
    41.         smtp = smtplib.SMTP()
    42.         smtp.connect(mail_host)
    43.         smtp.login(mail_user,mail_pass)
    44.         smtp.sendmail(me,mail_to,msg.as_string())
    45.         smtp.close()
    46.         sendstatus = True
    47.         print 'send ok'
    48.     except Exception,e:
    49.         senderr = str(e)
    50.         print senderr
    51.         endstatus = False
    53. if __name__ == "__main__":
    54.     cmd = "pt-table-checksum  --nocheck-replication-filters --no-check-binlog-format --replicate=test.checksums h='',u='',p='',P=3306,S=/tmp/mysql3306.sock -d test "
    55.     os.system(cmd)
    56.     mail_to = ['573242930@qq.com']
    57.     subject = '主从表数据不一致'
    58.     result = check_info()
    59.     nowtime = time.strftime( '%Y-%m-%d %X', time.localtime() )
    60.     output = ''
    61.     if result:
    62.         for m in result:
    63.             output += "库名：%s </br>" %m[0]
    64.             output += "表名：%s </br>" %m[1]
    65.         content = "%s </br>%s" % (nowtime,output)
    66.         send_mail(mail_to,subject,content)