pythonスクリプトはzabbixモニタリングデータを取得し、メールで送信します.
#!/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', 'p_w_upload', filename='damo.xlsx')
msg.attach(xlsxpart)
#
text=" ， ！"
# ,
part1 = MIMEText(text, 'plain', _charset='utf-8')
msg.attach(part1)
#
to="[email protected],[email protected]"
to=string.splitfields(to,",")
msg['from'] = '[email protected]'
msg['subject'] = ' '.decode('utf-8')
#
try:
server = smtplib.SMTP()
#
server.connect('smtp.163.com')
# ,
server.login('[email protected]', '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に迷惑メールとして拒否されやすい!自分のメールサーバーで送ったほうがいいです!