获取zabbix监控数据
#!/usr/bin/python3
# @Date: 2020/8/20 14:16
# @Author: zhangcheng
# @email: 3359957053@qq.com
# -*- coding: utf-8 -*-import pymysql
import time,datetime
import math#zabbix数据库信息:
zdbhost = "192.168.63.141"
zdbuser = "zabbix"
zdbpass = "zabbix"
zdbport = 3306
zdbname = "zabbix"#需要查询的key列表
keys = {#'trends_uint':[# # 'vfs.fs.size[/,used]',# 'vm.memory.size[available]',# 'vm.memory.size[total]',#],'trends':['system.cpu.util[,user,avg5]',#'system.cpu.util[,idle]',# 'system.cpu.num',],}class ReportForm:def __init__(self):'''打开数据库连接'''self.conn = pymysql.connect(host=zdbhost,user=zdbuser,passwd=zdbpass,port=zdbport,db=zdbname,charset="utf8")self.cursor = self.conn.cursor()#生成zabbix哪个分组报表self.groupname = "总部"#获取IP信息:self.IpInfoList = self.__getHostList()def __getHostList(self):'''根据zabbix组名获取该组所有IP'''#查询组ID:sql = '''select groupid from hstgrp where name = "{0}"'''.format(self.groupname)self.cursor.execute(sql)groupid = self.cursor.fetchone()[0]#根据groupid查询该分组下面的所有主机ID(hostid):sql = '''select hostid from hosts_groups where groupid = {0}'''.format(groupid)self.cursor.execute(sql)hostlist = [i for i in list("%s" %j for j in self.cursor.fetchall())]# ['10550', '10551', '10552', '10553', '10555', '10556', '10557', '10558', '10559', '10560', '10561', '10562','10563', '10564']#生成IP信息字典:结构为{'112.111.222.55':{'hostid':'10086L'},}IpInfoList = {}for hostid in hostlist:sql = '''select host from hosts where status = 0 and hostid = {0}'''.format(hostid)ret = self.cursor.execute(sql)if ret:IpInfoList["".join("%s" %i for i in list(self.cursor.fetchone()))] = {'hostid':hostid}return IpInfoListdef __getItemid(self,hostid,itemname):'''获取itemid'''sql = '''select itemid from items where hostid = {0} and key_ = "{1}" '''.format(hostid, itemname)#print(sql)if self.cursor.execute(sql):itemid = "".join("%s" %i for i in list(self.cursor.fetchone()))else:print(hostid,itemname)itemid = Nonereturn itemiddef getTrendsValue(self,itemid, start_time, stop_time):'''查询trends_uint表的值,type的值为min,max,avg三种'''resultlist = {}for type in ['avg']:sql = '''select {0}(value_{1}) as result from trends where itemid = '{2}' and clock >= '{3}' and clock <= '{4}' '''.format(type, type, itemid, start_time, stop_time)self.cursor.execute(sql)print(sql)result = self.cursor.fetchone()[0]if result == None:result = 0resultlist[type] = resultreturn resultlistdef getTrends_uintValue(self,itemid, start_time, stop_time):'''查询trends_uint表的值,type的值为min,max,avg三种'''resultlist = {}for type in ['avg']:sql = '''select {0}(value_{1}) as result from trends_uint where itemid = {2} and clock >= {3} and clock <= {4}'''.format(type, type, itemid, start_time, stop_time)self.cursor.execute(sql)result = self.cursor.fetchone()[0]if result:resultlist[type] = resultelse:resultlist[type] = 0return resultlistdef getLastMonthData(self,hostid,table,itemname):'''根据hostid,itemname获取该监控项的值'''#获取上个月的第一天和最后一天ts_first = int(time.mktime(datetime.date(datetime.date.today().year,datetime.date.today().month,1).timetuple()))lst_last = datetime.date(datetime.date.today().year,datetime.date.today().month,1)-datetime.timedelta(1)# lst_last = datetime.date(datetime.date.today().year,datetime.date.today().month+1,1)-datetime.timedelta(1)ts_last = int(time.mktime(lst_last.timetuple()))# print(ts_lnow_time =int(time.mktime(datetime.datetime.now().timetuple()))#print(now_time)#print(now_time)itemid = self.__getItemid(hostid, itemname)function = getattr(self,'get{0}Value'.format(table.capitalize()))return function(itemid, now_time, ts_last)def getInfo(self):#循环读取IP列表信息for ip,resultdict in zabbix.IpInfoList.items():print("正在查询 IP:%-15s hostid:%5d 的信息" %(ip,int(resultdict['hostid'])))#循环读取keys,逐个key统计数据:for table, keylists in keys.items():for key in keylists:print(" 正在统计 key_:'{0}'".format(key))#print(" 正在统计 key_:'{0}'".format(key))#print(" 正在统计 key_:'{0}'".format(table))data = zabbix.getLastMonthData(resultdict['hostid'],table,key)zabbix.IpInfoList[ip][key] = datadef writeToXls(self):'''生成xls文件'''try:import xlsxwriterdate = time.strftime("%Y-%m",time.localtime())#创建文件'filename=self.groupname + "-" +date + ".xlsx"workbook = xlsxwriter.Workbook(filename)#创建工作薄worksheet = workbook.add_worksheet()#写入标题(第一行)i = 0#for value in ["归属部门","主机","CPU核数","CPU平均空闲值","CPU最小空闲值","CPU15分钟负载"]:for value in ["归属部门", "主机", "CPU负载"]:worksheet.write(0,i, value)i = i + 1#写入内容:j = 1for ip,value in self.IpInfoList.items():worksheet.write(j, 0, self.groupname)worksheet.write(j,1, ip)#print(value['system.cpu.num']['avg'])#worksheet.write(j,2, '{}'.format(value['system.cpu.num']['avg']))worksheet.write(j,2, '{:.2f}%'.format(value['system.cpu.util[,user,avg5]']['avg']))# worksheet.write(j,4, '{:.2f}%'.format(value['system.cpu.util[,idle]']['min']))#worksheet.write(j,1, '{:.2f}'.format(value['system.cpu.util[all,user,avg5]']['avg']))#worksheet.write(j,6, '{}GB'.format(math.ceil(value['vm.memory.size[total]']['avg'] / 1024 / 1024 / 1024)))#worksheet.write(j,7, '{}GB'.format(math.ceil(value['vm.memory.size[available]']['avg'] / 1024 / 1024 / 1024)))#worksheet.write(j,8, '{}GB'.format(math.ceil(value['vm.memory.size[available]']['min'] / 1024 / 1024 / 1024)))j = j + 1workbook.close()except Exception as e:print(e)def __del__(self):'''关闭数据库连接'''self.cursor.close()self.conn.close()if __name__ == "__main__":zabbix = ReportForm()zabbix.getInfo()zabbix.writeToXls()
获取zabbix监控数据相关推荐
- grafana监控oracle11g,Grafana展示zabbix监控数据
一.安装步骤 (1)进入官网选择合适的操作系统版本下载Grafana:https://grafana.com/grafana/download?platform=linux [root@zabbix- ...
- python 监视图_python获取zabbix监控图
领导有个需求,希望每天邮件发出当天服务器的监控状态,开始是每天下午快下班的时候打开zabbix截图,每天都这样实在是累,于是写了一段脚本实现自动抓取图片,并组装成html,通过定时邮件发送,实现日报自 ...
- 使用zabbix监控数据并实现邮件、电话、微信报警
前言 zabbix 作为一款优秀的企业级开源监控系统,它可以采集和处理所有类型的监控数据,具有灵活的报警机制.与cacti 与 nagios相比,cacti画图比nagios漂亮,但是报警相对较弱,而 ...
- api查询所有记录 zabbix_通过Zabbix API获取历史监控数据
Zabbix API可以通过JSON RPC协议来获取历史数据. 可以采用脚本或者任何支持JSON RPC的工具来使用API. 基本请求格式 Zabbix API 简化的JSON请求如下: { &qu ...
- 数据分析(二)-zabbix/influxdb监控数据提取
一.zabbix监控数据提取 此次个人作业中所使用的zabbix的CSV数据是通过手动导出的方式,从mariadb的数据库中导出的,主要导出过程如下: 首先我的zabbix安装了php的可视化插件,在 ...
- 05: zabbix 监控配置
目录:zabbix其他篇 01: 安装zabbix server 02:zabbix-agent安装配置 及 web界面管理 03: zabbix API接口 对 主机.主机组.模板.应用集.监控项. ...
- zabbix监控教程
来源:B站.CSDN.微信公众号等平台整理,非商用! 1.什么是监控,为什么需要监控 监控:监视,控制 随着用户的增多,服务随时可能会被系统oom out of memory 内存溢出 kill -9 ...
- 阿里云API-python脚本开发-云监控数据对接nightingale监控
背景 在日常工作场景中,使用阿里云ECS.RDS等服务时,我们可能需要对接本公司选择的监控软件,用以实现便捷监控.阿里云也提供了相应的API,并且阿里云很贴心的提供了各种语言环境的演示代码,所以我们可 ...
- Zabbix监控Kafka topic积压数据
Kafka Apache Kafka是一个分布式发布-订阅消息系统和一个强大的队列,可以处理大量的数据,并使您能够将消息从一个端点传递到另一个端点. Kafka适合离线和在线消息消费. Kafka消息 ...
最新文章
- 2022-2028年中国加密货币行业市场研究及前瞻分析报告
- java 遍历方法_Java ArrayList遍历的3种方法
- python的编译器有哪些-python编译器有哪些
- java易语言_java程序员,0基础学习开发易语言。
- 《个体软件过程》—第1章1.1节什么是软件工程
- 中后端管理系统前后分离、前端框架的实现拙见
- 吴恩达|机器学习作业7.1.主成分分析(PCA)
- 计算机的组成 —— 显卡
- 禅道备份功能_禅道数据库备份
- c语言void nzp,二级C语言考试辅导教程第五章:函数[5]
- Rust: flat_map、filter_map、for_each
- CCNA CCNP全套教材 CCNA CCNP视频 CCNA CCNP最新题库解析
- 音阶频率对照表_各个音阶的对应频率
- 双屏1920*1080时全屏显示PPT时,出现第二块屏分辨率自动降低的问题
- 炸了~Redis bigkey导致生产事故-bigkey问题全面分析
- 转载英文单词备忘录词汇
- 工作英语: Meetings
- [原创]记某app内购破解 – 安卓逆向菜鸟的初体验
- 散粉在哪个步骤用_定妆粉是在哪个步骤用
- 题目内容: 写一个将华氏温度转换成摄氏温度的程序,转换的公式是: °F = (9/5)*°C + 32 其中C表示摄氏温度,F表示华氏温度。 程序的输入是一个整数,表示华氏温度。输出对
热门文章
- java管理员登录_idea实现管理员登录javaweb
- 设置 Visual Studio 字体/背景/行号 - C语言零基础入门教程
- move std 函数 示例_C++ STL迭代器辅助函数
- mysql访问60s出现timeout_websocket 每60s报WsHttpUpgradeHandler.timeoutAsync
- 云虚机php.ini在,虚拟主机php.ini在哪
- php suse 安装mysql_SUSE Linux apache,Mysql,php,svn的安装
- python文本特征选择,机器学习--特征选择(Python实现)
- 转码java,java转码
- linux 硬盘空间监控,Linux服务器硬盘空间监控
- dsm php,docker dsm是什么?