监控mysql的队列

import mysql.connector
from mysql.connector import Error

def monitor_mysql_queue(host, database, user, password):
    try:
        connection = mysql.connector.connect(host=host,
                                             database=database,
                                             user=user,
                                             password=password)

        if connection.is_connected():
            cursor = connection.cursor()
            cursor.execute("SHOW PROCESSLIST")
            rows = cursor.fetchall()

            for row in rows:
                print(f"ID: {row[0]}, User: {row[1]}, Host: {row[2]}, DB: {row[3]}, Command: {row[4]}, Time: {row[5]}, State: {row[6]}, Info: {row[7]}")

    except Error as e:
        print(f"Error: {e}")
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()

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