python脚本获取zabbix监控数据,并且通过邮件发送
2016-12-21 14:55
961 查看
#!/usr/bin/python #coding:utf-8 import MySQLdb import time,datetime from email.mime.multipart import MIMEMultipart from email.mime.text import MIMEText from email.mime.application import MIMEApplication import smtplib import string #zabbix数据库信息: zdbhost = '192.168.47.128' zdbuser = 'root' zdbpass = 'root' zdbport = 3306 zdbname = '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]', ], } class ReportForm: 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 = 'Test_Server' #获取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()['groupid'] #根据groupid查询该分组下面的所有主机ID(hostid): sql = '''select hostid from hosts_groups where groupid = %s''' % groupid self.cursor.execute(sql) hostlist = self.cursor.fetchall() #生成IP信息字典:结构为{'112.111.222.55':{'hostid':10086L,},} IpInfoList = {} for i in hostlist: hostid = i['hostid'] sql = '''select host from hosts where status = 0 and hostid = %s''' % hostid ret = self.cursor.execute(sql) if ret: IpInfoList[self.cursor.fetchone()['host']] = {'hostid':hostid} return IpInfoList def __getItemid(self,hostid,itemname): '''获取itemid''' sql = '''select itemid from items where hostid = %s and key_ = '%s' ''' % (hostid, itemname) if self.cursor.execute(sql): itemid = self.cursor.fetchone()['itemid'] else: itemid = None return itemid def getTrendsValue(self,itemid, start_time, stop_time): '''查询trends_uint表的值,type的值为min,max,avg三种''' resultlist = {} for type in ['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) self.cursor.execute(sql) result = self.cursor.fetchone()['result'] if result == None: result = 0 resultlist[type] = result return resultlist def getTrends_uintValue(self,itemid, start_time, stop_time): '''查询trends_uint表的值,type的值为min,max,avg三种''' resultlist = {} for type in ['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) self.cursor.execute(sql) result = self.cursor.fetchone()['result'] if result: resultlist[type] = int(result) else: resultlist[type] = 0 return resultlist def getLastMonthData(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()) return function(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 table, keylists in keys.items(): for key in keylists: print "\t正在统计 key_:%s" % key data = zabbix.getLastMonthData(resultdict['hostid'],table,key) zabbix.IpInfoList[ip][key] = data def writeToXls(self): '''生成xls文件''' try: import xlsxwriter #创建文件 workbook = xlsxwriter.Workbook('damo.xls') #创建工作薄 worksheet = workbook.add_worksheet() #写入标题(第一行) i = 0 for value in ["主机","CPU平均空闲值","CPU最小空闲值","可用平均内存(单位M)","可用最小内存(单位M)","CPU5分钟负载","进入最大流量(单位Kbps)","进入平均流量(单位Kbps)","出去最大流量(单位Kbps)","出去平均流量(单位Kbps)"]: worksheet.write(0,i, value.decode('utf-8')) i = i + 1 #写入内容: j = 1 for ip,value in self.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 + 1 workbook.close() except Exception,e: print e def __del__(self): '''关闭数据库连接''' self.cursor.close() self.conn.close() def sendEmail(self): # 创建一个带附件的实例 msg = MIMEMultipart() # 构造附件1 xlsxpart = MIMEApplication(open('damo.xls', 'rb').read()) xlsxpart.add_header('Content-Disposition', 'attachment', filename='damo.xlsx') msg.attach(xlsxpart) # 写入邮件正文 text=" 附件为运维监控报表,请查收!" # 邮件正文乱码,所以在这里指定编码 part1 = MIMEText(text, 'plain', _charset='utf-8') msg.attach(part1) # 加邮件 to="xxxxx@qq.com,xxxxx@163.com" to=string.splitfields(to,",") msg['from'] = 'xxxxxx@163.com' msg['subject'] = '运维部门监控统计报表'.decode('utf-8') # 发送邮件 try: server = smtplib.SMTP() # 数据中心测试时 server.connect('smtp.163.com') # 用户名,密码 server.login('xxxxx@163.com', '123456') server.sendmail(msg['from'], to, msg.as_string()) server.quit() print 'sucessfule'.decode("utf-8") except Exception, e: print str(e) if __name__ == "__main__": zabbix = ReportForm() zabbix.getInfo() zabbix.writeToXls() zabbix.sendEmail()注意:发送的邮件很容易被163当作垃圾邮件拒绝了!最好用自己的邮箱服务器发送!
相关文章推荐
- Python脚本通过邮件发送zabbix报警图片
- 监控redis和zookpeer服务脚本 并且python发送邮件
- zabbix增加手机短信、邮件监控的注意要点,SSL邮件发送python脚本
- zabbix通过python脚本发告警邮件
- 如何通过Zabbix获取监控数据?
- zabbix利用python脚本发送报警邮件的方法
- python监控脚本,监控CPU,磁盘报警时发送邮件
- Python通过smtp服务发送电子邮件给指定用户(适用于Zabbix邮件报警)
- 通过Zabbix API获取历史监控数据
- 通过python脚本和zabbix配合监控zookeeper的节点数
- Git学习-->如何通过Shell脚本实现 监控Gitlab备份整个过程并且通过邮件通知得到备份结果?
- [置顶] 使用Python获取每天最新CVE漏洞信息,通过邮件进行预警发送(二)
- python监控文件,并且发送告警邮件
- python监控文件并且发送告警邮件
- 在服务器上使用python自动获取zabbix上图形并发送邮件
- zabbix通过python脚本发告警邮件
- zabbix 通过python脚本将报警信息发送到rabbitMQ
- 调用阿里云api获取阿里云数据同步服务(DTS)并且作图发送邮件的整个流程
- 如何通过Zabbix获取监控数据?
- python连接oracel数据库,提取数据后制图并通过邮件发送