mysql 性能监控脚本

import mysql.connector
import time

def get_mysql_stats(host, user, password, database):
    conn = mysql.connector.connect(host=host, user=user, password=password, database=database)
    cursor = conn.cursor()
    
    # 获取连接数
    cursor.execute("SHOW STATUS LIKE 'Threads_connected'")
    threads_connected = cursor.fetchone()[1]
    
    # 获取查询响应时间
    cursor.execute("SHOW GLOBAL STATUS LIKE 'Uptime'")
    uptime = cursor.fetchone()[1]
    cursor.execute("SHOW GLOBAL STATUS LIKE 'Com_select'")
    com_select = cursor.fetchone()[1]
    query_response_time = (uptime / com_select) if com_select else 0
    
    cursor.close()
    conn.close()
    
    return threads_connected, query_response_time

if __name__ == "__main__":
    host = "your_mysql_host"
    user = "your_mysql_user"
    password = "your_mysql_password"
    database = "your_database_name"
    
    while True:
        threads_connected, query_response_time = get_mysql_stats(host, user, password, database)
        print(f"Threads Connected: {threads_connected}, Query Response Time: {query_response_time} s")
        time.sleep(10)  # 每隔10秒采集一次数据