python监控主机磁盘

Posted 2020-08-24

通过PYTHON实现主机磁盘的使用情况，使用influxdb+grafana来可是互展示

#!/usr/bin/env python

# _*_ coding:utf-8 _*_

import os

import re

import json

import time

from influxdb import InfluxDBClient

def getInfluxdb():

        client=InfluxDBClient(host=‘192.168.15.104‘, port=8086, username=‘admin‘, password=‘root123‘, database=‘mydb‘)

        return client

def check_hd_use():

    cmd_get_hd_use=‘/bin/df‘

    try:

        fp=os.popen(cmd_get_hd_use)

    except:

        ErrorInfo=r‘get_hd_use_error‘

#       print ErrorInfo

        return ErrorInfo

    r_search=re.compile(r‘^/dev/.+\s+(?P<Used>\d+)%\s+(?P<Mount>.+)‘)

    hd_use={}

    for line in fp:

        match=re.search(r_search,line)

        #print ‘......‘,match,

        if match is not None:

            hd_use[match.groupdict()[‘Mount‘]]=match.groupdict()[‘Used‘]

    fp.close()

    #print hd_use

    return hd_use

if __name__==‘__main__‘:

        disk=check_hd_use()

        disk_key=disk.keys()

        disk_key1=disk_key[0]

        disk_key2=disk_key[1]

        disk_value=disk.values()

        disk_value1=disk_value[0]

        disk_value2=disk_value[1]

        current=int(time.time())

        json_body=[{

                "measurement":"disk_use",

                "tags":{"host":"disk_check",

                "time":current

                },

                "fields":{

                disk_key1:int(disk_value1),

                disk_key2:int(disk_value2)

                #‘a‘:disk

                }

             }]

        getInfluxdb().write_points(json_body)

        print json_body

总结：

    需要注意，目前这个代码获取的是/,/home的2个磁盘的情况，若有跟多直接添加disk_key,disk_value值                              

本文出自 “DBSpace” 博客，请务必保留此出处http://dbspace.blog.51cto.com/6873717/1884020