zoukankan      html  css  js  c++  java
  • Mysql 监控脚本

    cat mysql_status_output.py
    #coding=utf-8
    import jaydebeapi
    import sys
    import pymysql
    import os
    from prometheus_client import Gauge,start_http_server
    import time
    #v_host=os.popen('echo $HOSTNAME')
    #hostname=v_host.read()
    #hstname="".join(hostname)
    #print(hostname.strip())
    class MySQL_Status_Output:
        def __init__(self,host,port,user,password):
            try:
                self.db = pymysql.connect(host=host,port=port,user=user,password=password)
                self.cursor = self.db.cursor()
            except Exception as e:
                print('Wrong')
                print(e)
        def mysql_status_select(self,x):
            try:
                sql='show global status like %s'
                data=x
                self.cursor.execute(sql,data)
                v_result=self.cursor.fetchall()
                return v_result
            except Exception as e:
                print(e)
        def mysql_select_sql(self,sql):
            try:
                self.cursor.execute(sql)
                v_result=self.cursor.fetchall()
                return v_result
            except Exception as e:
                print(e)
        def close(self):
            self.db.close()
    if __name__ == "__main__":
        start_http_server(9400)
        mysqlGauge = Gauge('mysqlGauge','Description of gauge', ['mylabelname'])
        while True:
            try:
                time.sleep(1)
                pro_db = MySQL_Status_Output('127.0.0.1',3306,'dbadmin','dbadmin')
                my_result = pro_db.mysql_select_sql('select MONITOR_NAME from dbadmin.db_monitor_tab where status=1 and MONITOR_NAME is not null')
                for j in range(len(my_result)):
                    monitor_name = "".join(tuple(my_result[j]))
                    v_out = pro_db.mysql_status_select(monitor_name)
                    for i in range(int(len(v_out))):
                        mysqlGauge.labels(mylabelname=v_out[i][0]).set(v_out[i][1])
                pro_db.close()
            except Exception as e:
                print('Is Wrong')
                print(e)
  • 相关阅读:
    聊聊mysql中的int(1)
    如何有效防止sql注入
    微信小程序WXML页面常用语法(讲解+示例)
    Spring Boot 2.x基础教程:使用集中式缓存Redis
    基于.NetCore3.1系列 —— 日志记录之自定义日志组件
    精讲RestTemplate第10篇-使用代理作为跳板发送请求
    使用Java API进行tar.gz文件及文件夹压缩解压缩
    精讲RestTemplate第9篇-如何通过HTTP Basic Auth认证
    精讲RestTemplate第8篇-请求失败自动重试机制
    精讲RestTemplate第7篇-自定义请求失败异常处理
  • 原文地址:https://www.cnblogs.com/xibuhaohao/p/10750012.html
Copyright © 2011-2022 走看看