Python+Mysql生成zabbix统计数据，,先大概了解一下zab

Python+Mysql生成zabbix统计数据，,先大概了解一下zab

先大概了解一下zabbix数据库结构：

1、groups表

可以根据组名查到组ID

2、找到组ID就可以根据组ID找出这个组下面的所有服务器的ID，这个关系在hosts_groups表里面：

3、有了hostid就可以在hosts表里查看这台机器的基本信息了：

items表则可以根据hostid查出这台服务器的所有监控项：

4、终于在items表查到itemid，利用这个itemid在trends和trends_uint这两个表中统计出我们需要的数据

我python水平挺菜的，很多面向对象的功能都不知道咋用，求大神教育

#!/usr/bin/python#coding:utf-8importMySQLdbimporttime,datetime#zabbix数据库信息：zdbhost=‘192.168.1.1‘zdbuser=‘zabbix‘zdbpass=‘zabbixreport‘zdbport=3306zdbname=‘zabbix‘#需要查询的key列表keys={‘trends_uint‘:[‘net.if.in[eth0]‘,‘net.if.out[eth0]‘,‘vfs.fs.size[/,used]‘,‘vm.memory.size[available]‘,],‘trends‘:[‘system.cpu.load[percpu,avg5]‘,‘system.cpu.util[,idle]‘,],}classReportForm:def__init__(self):‘‘‘打开数据库连接‘‘‘self.conn=MySQLdb.connect(host=zdbhost,user=zdbuser,passwd=zdbpass,port=zdbport,db=zdbname)self.cursor=self.conn.cursor(cursorclass=MySQLdb.cursors.DictCursor)#生成zabbix哪个分组报表self.groupname=‘qjsh‘#获取IP信息：self.IpInfoList=self.__getHostList()def__getHostList(self):‘‘‘根据zabbix组名获取该组所有IP‘‘‘#查询组ID:sql=‘‘‘selectgroupidfromgroupswherename=‘%s‘‘‘‘%self.groupnameself.cursor.execute(sql)groupid=self.cursor.fetchone()[‘groupid‘]#根据groupid查询该分组下面的所有主机ID（hostid）：sql=‘‘‘selecthostidfromhosts_groupswheregroupid=%s‘‘‘%groupidself.cursor.execute(sql)hostlist=self.cursor.fetchall()#生成IP信息字典：结构为{‘119.146.207.19‘:{‘hostid‘:10086L,},}IpInfoList={}foriinhostlist:hostid=i[‘hostid‘]sql=‘‘‘selecthostfromhostswherestatus=0andhostid=%s‘‘‘%hostidret=self.cursor.execute(sql)ifret:IpInfoList[self.cursor.fetchone()[‘host‘]]={‘hostid‘:hostid}returnIpInfoListdef__getItemid(self,hostid,itemname):‘‘‘获取itemid‘‘‘sql=‘‘‘selectitemidfromitemswherehostid=%sandkey_=‘%s‘‘‘‘%(hostid,itemname)ifself.cursor.execute(sql):itemid=self.cursor.fetchone()[‘itemid‘]else:itemid=NonereturnitemiddefgetTrendsValue(self,itemid,start_time,stop_time):‘‘‘查询trends_uint表的值,type的值为min,max,avg三种‘‘‘resultlist={}fortypein[‘min‘,‘max‘,‘avg‘]:sql=‘‘‘select%s(value_%s)asresultfromtrendswhereitemid=%sandclock>=%sandclock<=%s‘‘‘%(type,type,itemid,start_time,stop_time)self.cursor.execute(sql)result=self.cursor.fetchone()[‘result‘]ifresult==None:result=0resultlist[type]=resultreturnresultlistdefgetTrends_uintValue(self,itemid,start_time,stop_time):‘‘‘查询trends_uint表的值,type的值为min,max,avg三种‘‘‘resultlist={}fortypein[‘min‘,‘max‘,‘avg‘]:sql=‘‘‘select%s(value_%s)asresultfromtrends_uintwhereitemid=%sandclock>=%sandclock<=%s‘‘‘%(type,type,itemid,start_time,stop_time)self.cursor.execute(sql)result=self.cursor.fetchone()[‘result‘]ifresult:resultlist[type]=int(result)else:resultlist[type]=0returnresultlistdefgetLastMonthData(self,hostid,table,itemname):‘‘‘根据hostid,itemname获取该监控项的值‘‘‘#获取上个月的第一天和最后一天ts_first=int(time.mktime(datetime.date(datetime.date.today().year,datetime.date.today().month-1,1).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())returnfunction(itemid,ts_first,ts_last)defgetInfo(self):#循环读取IP列表信息forip,resultdictinzabbix.IpInfoList.items():print"正在查询IP:%-15shostid:%5d的信息！"%(ip,resultdict[‘hostid‘])#循环读取keys，逐个key统计数据：fortable,keylistsinkeys.items():forkeyinkeylists:print"\t正在统计key_:%s"%keydata=zabbix.getLastMonthData(resultdict[‘hostid‘],table,key)zabbix.IpInfoList[ip][key]=datadefwriteToXls(self):‘‘‘生成xls文件‘‘‘try:importxlsxwriter#创建文件workbook=xlsxwriter.Workbook(‘damo.xls‘)#创建工作薄worksheet=workbook.add_worksheet()#写入标题（第一行）i=0forvaluein["主机","CPU平均空闲值","CPU最小空闲值","可用平均内存(单位M)","可用最小内存(单位M)","CPU5分钟负载","进入最大流量（单位Kbps）","进入平均流量（单位Kbps）","出去最大流量（单位Kbps）","出去平均流量（单位Kbps）"]:worksheet.write(0,i,value.decode(‘utf-8‘))i=i+1#写入内容：j=1forip,valueinself.IpInfoList.items():worksheet.write(j,0,ip)worksheet.write(j,1,‘%.2f‘%value[‘system.cpu.util[,idle]‘][‘avg‘])worksheet.write(j,2,‘%.2f‘%value[‘system.cpu.util[,idle]‘][‘min‘])worksheet.write(j,3,‘%dM‘%int(value[‘vm.memory.size[available]‘][‘avg‘]/1024/1024))worksheet.write(j,4,‘%dM‘%int(value[‘vm.memory.size[available]‘][‘min‘]/1024/1024))worksheet.write(j,5,‘%.2f‘%value[‘system.cpu.load[percpu,avg5]‘][‘avg‘])worksheet.write(j,6,value[‘net.if.in[eth0]‘][‘max‘]/1000)worksheet.write(j,7,value[‘net.if.in[eth0]‘][‘avg‘]/1000)worksheet.write(j,8,value[‘net.if.out[eth0]‘][‘max‘]/1000)worksheet.write(j,9,value[‘net.if.out[eth0]‘][‘avg‘]/1000)j=j+1workbook.close()exceptException,e:printedef__del__(self):‘‘‘关闭数据库连接‘‘‘self.cursor.close()self.conn.close()if__name__=="__main__":zabbix=ReportForm()zabbix.getInfo()zabbix.writeToXls()

生成xls文件我用了一个叫xlsxwriter的第三方库，这个库只能写不能读，感觉还可以，生成出来的效果：

本文出自 “运维笔记” 博客，请务必保留此出处http://lihuipeng.blog.51cto.com/3064864/1533315

Python+Mysql生成zabbix统计数据,布布扣,bubuko.com

Python+Mysql生成zabbix统计数据