mysql 监控点

import pymysql
import time

# 连接数据库
conn = pymysql.connect(host='localhost', user='root', password='password', db='test')

def get_connection_count():
    with conn.cursor() as cursor:
        cursor.execute("SHOW STATUS LIKE 'Threads_connected'")
        result = cursor.fetchone()
        return int(result[1])

def get_slow_queries():
    with conn.cursor() as cursor:
        cursor.execute("SHOW VARIABLES LIKE 'slow_query_log'")
        slow_query_log_enabled = cursor.fetchone()[1] == 'ON'
        if slow_query_log_enabled:
            cursor.execute("SELECT * FROM mysql.slow_log LIMIT 10")
            return cursor.fetchall()
        else:
            return "Slow query log is not enabled."

while True:
    print(f"Current connections: {get_connection_count()}")
    print(f"Slow queries: {get_slow_queries()}")
    time.sleep(10)