import mysql.connectorfrom prometheus_client import Gauge, start_http_server# 连接 MySQL 数据库并获取指标信息def get_mysql_perf_indicators(host, port, user, password):cnx = mysql.connector.connect(user=user, password=password,host=host,port=port)cursor = cnx.cursor()cursor.execute("SHOW GLOBAL STATUS")indicators = {}for row in cursor:indicators[row[0]] = int(row[1])cnx.close()return indicators# 指标名称映射字典，用于将 MySQL 指标转换为 Prometheus Metrics 格式的指标名和帮助文本mysql_metrics_mapping = {'Bytes_received': ('mysql_network_bytes_received_total', 'Total number of bytes received from all clients'),'Bytes_sent': ('mysql_network_bytes_sent_total', 'Total number of bytes sent to all clients'),'Questions': ('mysql_queries_total', 'Total number of questions (queries) from clients'),}# 定义 Prometheus Metrics 格式的指标对象metrics = []for metric_name, help_text in mysql_metrics_mapping.values():metrics.append(Gauge(metric_name, help_text))# 启动 HTTP 服务器，监听在 8000 端口上start_http_server(8000)# 循环获取指标信息，并更新 Prometheus Metrics 指标对象的值while True:# 获取 MySQL 指标信息indicators = get_mysql_perf_indicators('localhost', 3306, 'root', 'password')# 更新 Prometheus Metrics 指标对象的值for mysql_metric_name, (prom_metric_name, _) in mysql_metrics_mapping.items():metrics_by_name[prom_metric_name].set(indicators.get(mysql_metric_name, 0))
在上述代码中，首先定义了 get_mysql_perf_indicators() 函数用于连接 MySQL 数据库并获取关键性能指标信息。然后，定义了 mysql_metrics_mapping 字典，用于将 MySQL 指标转换为 Prometheus Metrics 格式的指标名和帮助文本。接下来，创建了 Prometheus Metrics 格式的指标对象，并启动了 HTTP 服务器监听在 8000 端口上。最后，在一个无限循环中获取 MySQL 指标信息，并更新 Prometheus Metrics 指标对象的值。
示例输出结果：
# HELP mysql_network_bytes_received_total Total number of bytes received from all clients# TYPE mysql_network_bytes_received_total gaugemysql_network_bytes_received_total 12345.0# HELP mysql_network_bytes_sent_total Total number of bytes sent to all clients# TYPE mysql_network_bytes_sent_total gaugemysql_network_bytes_sent_total 67890.0# HELP mysql_queries_total Total number of questions (queries) from clients# TYPE mysql_queries_total gaugemysql_queries_total 100000.0
