监控MySQL主从同步的脚本

好的，下面给您提供一个简单的监控MySQL主从同步的脚本，使用Python编写：

import pymysql
import time
import smtplib
from email.mime.text import MIMEText
from email.header import Header


# MySQL主库和从库的配置信息
master_config = {
    'host': 'master_host',
    'port': 3306,
    'user': 'username',
    'password': 'password'
}

slave_config = {
    'host': 'slave_host',
    'port': 3306,
    'user': 'username',
    'password': 'password'
}

# 邮件发送配置信息
mail_host = 'smtp.gmail.com'
mail_port = 587
mail_user = 'your_email'
mail_password = 'your_password'
sender = 'your_email'
receivers = ['receiver_email']


def check_slave_status():
    # 连接MySQL从库
    slave_conn = pymysql.connect(**slave_config)
    slave_cursor = slave_conn.cursor()

    # 执行SHOW SLAVE STATUS命令，获取从库状态信息
    slave_cursor.execute('SHOW SLAVE STATUS')
    slave_status = slave_cursor.fetchone()

    # 关闭从库连接
    slave_cursor.close()
    slave_conn.close()

    # 判断从库状态是否正常
    if slave_status[10] == 'Yes' and slave_status[11] == 'Yes':
        return True
    else:
        return False


def send_mail(content):
    # 构造邮件内容
    message = MIMEText(content, 'plain', 'utf-8')
    message['From'] = Header("MySQL监控", 'utf-8')
    message['To'] = Header("管理员", 'utf-8')
    message['Subject'] = Header("MySQL主从同步异常", 'utf-8')

    # 发送邮件
    smtpObj = smtplib.SMTP(mail_host, mail_port)
    smtpObj.starttls()
    smtpObj.login(mail_user, mail_password)
    smtpObj.sendmail(sender, receivers, message.as_string())
    smtpObj.quit()


if __name__ == '__main__':
    while True:
        # 连接MySQL主库
        master_conn = pymysql.connect(**master_config)
        master_cursor = master_conn.cursor()

        # 执行一条SQL语句，插入一条测试数据
        insert_sql = "INSERT INTO test_table (name, age) VALUES ('test', 18)"
        master_cursor.execute(insert_sql)

        # 关闭主库连接
        master_cursor.close()
        master_conn.close()

        # 检查从库状态
        if not check_slave_status():
            # 发送告警邮件
            send_mail('MySQL主从同步异常，请及时处理！')

        # 每隔30秒执行一次
        time.sleep(30)

这个脚本的作用是每隔30秒向MySQL主库插入一条测试数据，并检查从库的状态是否正常。如果从库状态异常，则会发送一封告警邮件。需要注意的是，这只是一个简单的示例，实际应用中需要根据具体情况进行调整和优化。