mysql主从监控延迟量

import mysql.connector
import time

def get_slave_delay(master_host, master_port, master_user, master_password):
    master_conn = mysql.connector.connect(
        host=master_host,
        port=master_port,
        user=master_user,
        password=master_password
    )
    master_cursor = master_conn.cursor()
    master_cursor.execute("SHOW MASTER STATUS")
    master_status = master_cursor.fetchone()
    master_file = master_status[0]
    master_position = master_status[1]

    slave_conn = mysql.connector.connect(
        host='slave_host',
        port=slave_port,
        user=slave_user,
        password=slave_password
    )
    slave_cursor = slave_conn.cursor()
    slave_cursor.execute(f"SHOW SLAVE STATUS FOR CHANNEL 'default'")
    slave_status = slave_cursor.fetchone()
    slave_file = slave_status[5]
    slave_position = slave_status[6]

    master_cursor.close()
    master_conn.close()
    slave_cursor.close()
    slave_conn.close()

    if master_file == slave_file:
        return 0
    else:
        master_cursor = master_conn.cursor()
        master_cursor.execute(f"SHOW BINLOG EVENTS IN '{master_file}' FROM {master_position}")
        master_event_count = len(list(master_cursor.fetchall()))
        master_cursor.close()
        master_conn.close()

        slave_cursor = slave_conn.cursor()
        slave_cursor.execute(f"SHOW BINLOG EVENTS IN '{slave_file}' FROM {slave_position}")
        slave_event_count = len(list(slave_cursor.fetchall()))
        slave_cursor.close()
        slave_conn.close()

        return master_event_count - slave_event_count

if __name__ == "__main__":
    master_host = 'master_host'
    master_port = 3306
    master_user = 'master_user'
    master_password = 'master_password'

    while True:
        delay = get_slave_delay(master_host, master_port, master_user, master_password)
        print(f"Slave delay: {delay} events")
        time.sleep(5)