python脚本统计mysql慢查询

import mysql.connector
from mysql.connector import Error

def get_slow_queries(host, user, password, database, threshold):
    try:
        connection = mysql.connector.connect(host=host,
                                             user=user,
                                             password=password,
                                             database=database)
        cursor = connection.cursor()
        query = """
            SELECT * FROM mysql.slow_log
            WHERE start_time > NOW() - INTERVAL %s DAY
        """
        cursor.execute(query, (threshold,))
        slow_queries = cursor.fetchall()
        return slow_queries
    except Error as e:
        print(f"Error: {e}")
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()

if __name__ == "__main__":
    host = "localhost"
    user = "root"
    password = "your_password"
    database = "your_database"
    threshold = 7  # 统计过去7天的慢查询

    slow_queries = get_slow_queries(host, user, password, database, threshold)
    for query in slow_queries:
        print(query)