獲取Zabbix 中資源的使用率

import pymysql as MySQLdb
import time
import datetime
import xlsxwriter

# zabbix數據庫信息：
zdbhost = 'xxx.xxx.xxx.xxx'
zdbuser = 'MySQL-username'
zdbpass = MySQL-PassWord'
zdbport = 3306
zdbname = 'zabbix-DBName'

# 生成文件名稱：
xlsfilename = 'Group_Production_Server.xlsx'

# 需要查詢的key列表 [名稱，表名，key值，取值，格式化，數據整除處理]
keys = [
    ['CPU空閑率(%)', 'trends', 'system.cpu.util[,idle]', 'avg', '%.2f', 1],
    ['內存使用率(G)', 'trends_uint', 'vm.memory.size[total]', 'avg', '%.2f', 1],
    ['磁盤使用率(%)', 'trends', 'system.cpu.util[,iowait]', 'avg', '%.2f', 1],
]


class ReportForm(object):

    def __init__(self):
        """打開數據庫連接"""
        self.conn = MySQLdb.connect(host=zdbhost, user=zdbuser, passwd=zdbpass, port=zdbport, db=zdbname)
        self.cursor = self.conn.cursor()
        # 生成zabbix哪個分組報表
        self.groupname = 'Mysql'
        # 獲取IP信息：
        self.IpInfoList = self.__getHostList()

    def __getHostList(self):
        """根據zabbix組名獲取該組所有IP"""
        # 查詢組ID:
        sql = '''select groupid from groups where name = '%s' ''' % self.groupname
        self.cursor.execute(sql)
        groupid = self.cursor.fetchone()[0]
        # 根據groupid查詢該分組下面的所有主機ID（hostid）：
        sql = '''select hostid from hosts_groups where groupid = '%s' ''' % groupid
        self.cursor.execute(sql)
        hostlist = self.cursor.fetchall()
        # 生成IP信息字典：結構為{'119.146.207.19':{'hostid':10086L,},}
        IpInfoList = {}
        for i in hostlist:
            hostid = i[0]
            sql = '''SELECT ip from interface WHERE hostid = '%s' ''' % hostid
            ret = self.cursor.execute(sql)
            if ret:
                IpInfoList[self.cursor.fetchone()[0]] = {'hostid': hostid}
        return IpInfoList

    def __getItemid(self, hostid, itemname):
        """獲取itemid"""

        sql = '''select itemid from items where hostid = '%s' and key_ = '%s' ''' % (hostid, itemname)
        self.cursor.execute(sql)
        itemid = self.cursor.fetchone()[0]
        # print('hostid --> ', hostid)
        # print('itemid --> ', itemid)
        return itemid

    def getTrendsValue(self, type, itemid, start_time, stop_time):
        """查詢trends_uint表的值,type的值為min,max,avg三種"""

        sql = '''select %s(value_%s) as result from trends where itemid = '%s' and clock >= '%s' and clock <= '%s' ''' % (
            type, type, itemid, start_time, stop_time)
        # print('trends --> ', sql)
        self.cursor.execute(sql)
        result = self.cursor.fetchone()[0]
        if result == None:
            result = 0
        # print('trends - result --> ', result)
        return result

    def getTrends_uintValue(self, type, itemid, start_time, stop_time):
        """查詢trends_uint表的值,type的值為min,max,avg三種"""

        sql = '''select %s(value_%s) as result from trends_uint where itemid = '%s' and clock >= '%s' and clock <= '%s' ''' % (
            type, type, itemid, start_time, stop_time)
        # print('trends_uint --> ', sql)
        self.cursor.execute(sql)
        result = self.cursor.fetchone()[0] / 1073741824
        if result:
            result = int(result)
        else:
            result = 0
        # print('trends_uint - result--> ', result)
        return result

    def getLastMonthData(self, type, hostid, table, itemname):
        """根據hostid,itemname獲取該監控項的值"""

        # 獲取上個月的第20天和最后1天
        ts_first = int(
            time.mktime(datetime.date(datetime.date.today().year, datetime.date.today().month - 1, 20).timetuple()))
        lst_last = datetime.date(datetime.date.today().year, datetime.date.today().month, 1) - datetime.timedelta(1)
        ts_last = int(time.mktime(lst_last.timetuple()))
        itemid = self.__getItemid(hostid, itemname)
        function = getattr(self, 'get%sValue' % table.capitalize())
        return function(type, itemid, ts_first, ts_last)

    def getInfo(self):

        # 循環讀取IP列表信息
        for ip, resultdict in zabbix.IpInfoList.items():
            print("正在查詢 IP:%-15s hostid:%5d 的信息！" % (ip, resultdict['hostid']))
        # 循環讀取keys，逐個key統計數據：
            for value in keys:
                print("\t正在統計 key_:%s" % value[2])
                if not value[2] in zabbix.IpInfoList[ip]:
                    zabbix.IpInfoList[ip][value[2]] = {}
                data = zabbix.getLastMonthData(value[3], resultdict['hostid'], value[1], value[2])
                zabbix.IpInfoList[ip][value[2]][value[3]] = data

    def writeToXls2(self):
        """生成xls文件"""

        # 創建文件
        workbook = xlsxwriter.Workbook(xlsfilename)
        # 創建工作薄
        worksheet = workbook.add_worksheet()
        # 寫入第一列：
        worksheet.write(0, 0, "主機")
        i = 1
        for ip in self.IpInfoList:
            worksheet.write(i, 0, ip)
            i = i + 1
        # 寫入其他列：
        for i in range(1, 5):
            i = 1
            for value in keys:
                worksheet.write(0, i, value[0])
                # 寫入該列內容：
                j = 1
                for ip, result in self.IpInfoList.items():
                    if value[4]:
                        worksheet.write(j, i, value[4] % result[value[2]][value[3]])
                    else:
                        worksheet.write(j, i, result[value[2]][value[3]] / value[5])
                    j = j + 1
                i = i + 1
        workbook.close()

    def __del__(self):
        """關閉數據庫連接"""

        self.cursor.close()
        self.conn.close()


if __name__ == "__main__":
    zabbix = ReportForm()
    zabbix.getInfo()
    zabbix.writeToXls2()

參考: https://www.jb51.net/article/167771.htm