mysql中慢sql监控

import mysql.connector
from mysql.connector import Error

def monitor_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 information_schema.PROCESSLIST 
        WHERE TIME > %s;
        """
        cursor.execute(query, (threshold,))
        
        slow_queries = cursor.fetchall()
        
        for query in slow_queries:
            print(f"ID: {query[0]}, User: {query[1]}, Host: {query[2]}, DB: {query[3]}, Command: {query[4]}, Time: {query[5]}, State: {query[6]}, Info: {query[7]}")
    
    except Error as e:
        print(f"Error: {e}")
    
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()

# 示例调用
monitor_slow_queries('localhost', 'root', 'password', 'testdb', 5)