MySQL数据,查询QPS,TPS数据方式

-- 获取当前总查询次数（所有类型）
SHOW STATUS LIKE 'Queries';

-- 计算过去 N 秒的 QPS（例如 N=5）
SELECT 
    (NOW() - INTERVAL 5 SECOND) AS 时间差,  
    (SHOW STATUS LIKE 'Queries') - prev_queries AS 当前查询总数,
    ROUND((当前查询总数 / 时间差.total_seconds), 2) AS QPS
FROM 
    (SELECT SHOW STATUS LIKE 'Queries' AS prev_queries) AS subquery,
    (SELECT NOW() - INTERVAL 5 SECOND AS time_diff) AS time_diff;

-- 获取当前事务提交次数
SHOW STATUS LIKE 'Com_commit';

-- 计算过去 N 秒的 TPS（例如 N=5）
SELECT 
    (NOW() - INTERVAL 5 SECOND) AS 时间差,  
    (SHOW STATUS LIKE 'Com_commit') - prev_commits AS 当前提交总数,
    ROUND((当前提交总数 / 时间差.total_seconds), 2) AS TPS
FROM 
    (SELECT SHOW STATUS LIKE 'Com_commit' AS prev_commits) AS subquery,
    (SELECT NOW() - INTERVAL 5 SECOND AS time_diff) AS time_diff;

-- 检查是否已启用
SHOW VARIABLES LIKE 'performance_schema';

-- 若未启用，在 `my.cnf` 中添加：
[mysqld]
performance_schema = ON

SELECT 
    event_name       AS 查询类型,  
    COUNT_STAR        AS 总执行次数,  
    AVG_TIMER_WAIT    AS 平均延迟（微秒）,  
    SUM_TIMER_WAIT    AS 总延迟（微秒）
FROM 
    performance_schema.events_statements_summary_by_digest
WHERE 
    event_name IN ('SELECT', 'INSERT', 'UPDATE', 'DELETE')
ORDER BY 
    COUNT_STAR DESC;

SELECT 
    event_name       AS 事务类型,  
    COUNT_STAR        AS 提交次数,  
    AVG_TIMER_WAIT    AS 平均延迟（微秒）
FROM 
    performance_schema.events_statements_summary_by_digest
WHERE 
    event_name = 'COMMIT';

# 查看所有关键状态变量（包含 QPS 和 TPS）
mysqladmin -u root -p status

# 仅查看 QPS、TPS 和连接数
mysqladmin -u root -p extended-status | grep -E 'Queries|Com_commit|Threads_connected'

# 下载并运行 mysql_exporter
wget https://github.com/prometheus/mysqld_exporter/releases/download/v1.16.0/mysqld_exporter-1.16.0.linux-amd64.tar.gz
tar xvfz mysqld_exporter-*.tar.gz
cd mysqld_exporter-*/
./mysqld_exporter

# Prometheus 配置（`prometheus.yml`）
scrape_configs:
  - job_name: 'mysql'
    static_configs:
      - targets: ['localhost:9104']

# QPS：所有查询速率（每秒执行次数）
rate(mysql_statements_total{statement_type=~"SELECT|INSERT|UPDATE|DELETE"}[5m])

# TPS：事务提交速率（每秒提交次数）
rate(mysql_statements_total{statement_type="COMMIT"}[5m])

import mysql.connector
import time

def get_mysql_stats(host, user, password, db):
    conn = mysql.connector.connect(
        host=host,
        user=user,
        password=password,
        database=db
    )
    cursor = conn.cursor()
    
    # 查询 QPS
    cursor.execute("SHOW STATUS LIKE 'Queries'")
    queries_total = int(cursor.fetchone()[1])
    
    # 查询 TPS
    cursor.execute("SHOW STATUS LIKE 'Com_commit'")
    commits_total = int(cursor.fetchone()[1])
    
    cursor.close()
    conn.close()
    return queries_total, commits_total

if __name__ == "__main__":
    host = 'localhost'
    user = 'root'
    password = 'password'
    db = 'test'
    
    prev_queries, prev_commits = get_mysql_stats(host, user, password, db)
    
    while True:
        time.sleep(5)
        current_queries, current_commits = get_mysql_stats(host, user, password, db)
        
        qps = (current_queries - prev_queries) / 5
        tps = (current_commits - prev_commits) / 5
        
        print(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] QPS={qps:.2f}, TPS={tps:.2f}")
        
        prev_queries, prev_commits = current_queries, current_commits

# 分析慢查询日志并统计 QPS/TPS
pt-query-digest --slow-log=/var/log/mysql/slow.log --output=report