python + promethues 監(jiān)控mysql

需求

今天寫了個exporter監(jiān)控下剛投入使用的mysql主從的主機(jī)每窖。主要用到了python的flask和pymysql模塊。

程序

引入模塊毫缆。沒有的需要自己pip安裝

# coding=utf-8
#author:OrangeLoveMlian
#!/bin/python
#coding=utf-8
import pymysql
import pymysql.cursors
import sys
import prometheus_client
from prometheus_client.core import CollectorRegistry
from prometheus_client import Gauge
from flask import Response,Flask

登陸mysql,寫了一個探測函數(shù)洼滚,如果不能連接到mysql囊颅,返回0.說明mysql可能出現(xiàn)問題了湾戳。

###參數(shù)字典
config = {
    'host':'ip',
    'port':port,
    'user':'user',
    'password':'pwd',
    }

###獲取連接狀態(tài)

def connection_status():
    try:
        connection = pymysql.connect(**config)
        connection_status = 1
                connection.close()
        return connection_status
        
    except:
        connection_status = 0
        return connection_status

mysql的監(jiān)控參數(shù)主要通過show status獲得弟劲。利用pymysql執(zhí)行sql語句蟋软。取到參數(shù)值镶摘,并轉(zhuǎn)換成可讀性高的字典

###獲取mysql的狀態(tài)參數(shù)嗽桩,返回元組.如果連接不上,獲取的參數(shù)為0凄敢,程序退出
def getPara():
    i = connection_status()
    if i == 1:
        connection = pymysql.connect(**config)
        cursor = connection.cursor()
        sql = "show status"
        try:
            
            cursor.execute(sql)
            statusPara =  cursor.fetchall()
            return statusPara

        except Exception,e:

            print 'execute failed!'
            sys.exit()
                        return e
    else:
        
        print 'connection failed!'
        sys.exit()
                return 0

###將獲取的參數(shù)元組轉(zhuǎn)換成可讀性高的字典
def getMysqlStatusDic():

    tup = ()
    tup = getPara()
    tup = list(tup)
    for i in range(len(tup)):
        tup[i] = list(tup[i])
    statusDic = dict(tup)
    return statusDic

promethues使用pull的方式獲取參數(shù)的碌冶。所以用flask起了一個接口,返回gauge參數(shù)贡未。抓取了一些自己認(rèn)為重要的參數(shù)种樱,有待完善。


###起個flask接口,返回mysql的狀態(tài)參數(shù)查詢
app = Flask(__name__)
REGISTRY = CollectorRegistry(auto_describe=False)
##注冊的值
mysqlConnect = Gauge("mysqlConnect","Value is:",registry=REGISTRY)
mysqlUptime = Gauge("mysqlUptime","Value is:",registry=REGISTRY)
mysqlSlow_queries = Gauge("mysqlSlow_queries","Value is:",registry=REGISTRY)
mysqlThreads_connected = Gauge("mysqlThreads_connected","Value is:",registry=REGISTRY)
mysqlThreads_running = Gauge("mysqlThreads_running","Value is:",registry=REGISTRY)
mysqlConnection_errors_internal = Gauge("mysqlConnection_errors_internal","Value is:",registry=REGISTRY)
mysqlAborted_connects = Gauge("mysqlAborted_connects","Value is:",registry=REGISTRY)
mysqlInnodb_buffer_pool_pages_data = Gauge("mysqlInnodb_buffer_pool_pages_data","Value is:",registry=REGISTRY)
@app.route("/metrics")
def mysqlStatus():
    MS = getMysqlStatusDic()
    ###mysql是否可以連接
    
    mysqlConnect.set(connection_status())
    
    ###mysql啟動時間
    
    mysqlUptime.set(MS['Uptime'])
    
    ###慢查詢的個數(shù)
        
    mysqlSlow_queries.set(MS['Slow_queries'])

    #連接
    ###客戶端連接數(shù)俊卤,當(dāng)前開放的連接
        
    mysqlThreads_connected.set(MS['Threads_connected'])
    ###當(dāng)前運(yùn)行的連接
        
    mysqlThreads_running.set(MS['Threads_running'])
    ###服務(wù)器醋無導(dǎo)致的失敗的連接數(shù)
        
    mysqlConnection_errors_internal.set(MS['Connection_errors_internal'])
    ###嘗試與服務(wù)器連接失敗的個數(shù)
        
    mysqlAborted_connects.set(MS['Aborted_connects'])

    #緩沖池使用情況
    ###緩沖池中的總頁數(shù)
    
    mysqlInnodb_buffer_pool_pages_data.set(MS['Innodb_buffer_pool_pages_data'])
    ###資源池?zé)o法滿足的請求
        
    mysqlInnodb_buffer_pool_reads.set(MS['Innodb_buffer_pool_reads'])

    return Response(prometheus_client.generate_latest(REGISTRY),mimetype="text/plain")
    

if __name__ == "__main__":
    app.run(host='0.0.0.0',port=3534)

利用grafana展示抓取到的數(shù)據(jù)嫩挤,并設(shè)置告警


grafana展示
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市消恍,隨后出現(xiàn)的幾起案子岂昭,更是在濱河造成了極大的恐慌,老刑警劉巖狠怨,帶你破解...
    沈念sama閱讀 222,681評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件约啊,死亡現(xiàn)場離奇詭異,居然都是意外死亡佣赖,警方通過查閱死者的電腦和手機(jī)恰矩,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,205評論 3 399
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來憎蛤,“玉大人外傅,你說我怎么就攤上這事×┟剩” “怎么了萎胰?”我有些...
    開封第一講書人閱讀 169,421評論 0 362
  • 文/不壞的土叔 我叫張陵,是天一觀的道長棚辽。 經(jīng)常有香客問我技竟,道長,這世上最難降的妖魔是什么屈藐? 我笑而不...
    開封第一講書人閱讀 60,114評論 1 300
  • 正文 為了忘掉前任榔组,我火速辦了婚禮,結(jié)果婚禮上联逻,老公的妹妹穿的比我還像新娘瓷患。我一直安慰自己,他們只是感情好遣妥,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,116評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著攀细,像睡著了一般箫踩。 火紅的嫁衣襯著肌膚如雪爱态。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,713評論 1 312
  • 那天境钟,我揣著相機(jī)與錄音锦担,去河邊找鬼。 笑死慨削,一個胖子當(dāng)著我的面吹牛洞渔,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播缚态,決...
    沈念sama閱讀 41,170評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼磁椒,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了玫芦?” 一聲冷哼從身側(cè)響起浆熔,我...
    開封第一講書人閱讀 40,116評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎桥帆,沒想到半個月后医增,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,651評論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡老虫,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,714評論 3 342
  • 正文 我和宋清朗相戀三年叶骨,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片祈匙。...
    茶點(diǎn)故事閱讀 40,865評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡忽刽,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出菊卷,到底是詐尸還是另有隱情缔恳,我是刑警寧澤,帶...
    沈念sama閱讀 36,527評論 5 351
  • 正文 年R本政府宣布洁闰,位于F島的核電站歉甚,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏扑眉。R本人自食惡果不足惜纸泄,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,211評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望腰素。 院中可真熱鬧聘裁,春花似錦、人聲如沸弓千。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,699評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至镣陕,卻和暖如春谴餐,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背呆抑。 一陣腳步聲響...
    開封第一講書人閱讀 33,814評論 1 274
  • 我被黑心中介騙來泰國打工岂嗓, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人鹊碍。 一個月前我還...
    沈念sama閱讀 49,299評論 3 379
  • 正文 我出身青樓厌殉,卻偏偏與公主長得像,于是被迫代替她去往敵國和親侈咕。 傳聞我的和親對象是個殘疾皇子公罕,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,870評論 2 361

推薦閱讀更多精彩內(nèi)容