mysql 失效转移

import mysql.connector
from mysql.connector import pooling

# 创建数据库连接池
dbconfig = {
    "host": "master_host",
    "user": "user",
    "password": "password",
    "database": "database"
}
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **dbconfig)

def check_master():
    try:
        conn = pool.get_connection()
        cursor = conn.cursor()
        cursor.execute("SELECT 1")
        result = cursor.fetchone()
        if result[0] == 1:
            return True
        else:
            return False
    except mysql.connector.Error as err:
        return False
    finally:
        cursor.close()
        conn.close()

def failover():
    if not check_master():
        # 主数据库故障，执行失效转移
        conn = pool.get_connection()
        cursor = conn.cursor()
        cursor.execute("STOP SLAVE")
        cursor.execute("CHANGE MASTER TO MASTER_HOST='new_master_host', MASTER_USER='user', MASTER_PASSWORD='password', MASTER_LOG_FILE='new_log_file', MASTER_LOG_POS=new_log_pos")
        cursor.execute("START SLAVE")
        cursor.close()
        conn.close()

# 定期检查主数据库状态并执行失效转移
while True:
    failover()
    time.sleep(60)