如何采用Python zabbix

最近领导需要一份数据,OpenStack ,VMware,物理机之间的性能报告,在撰写报告之前需要数据支撑,我们采用的是zabbix 监控,需要采取一周内的历史数据作为对比,那数据如何获取,请看以下章节 

一:安装zabbix api 接口,修改zabbix api 调用接口,获取数据、

*****************************************************************************************
easy_install zabbix_api
*****************************************************************************************
 
   
 
#!/usr/bin/Python
 
# The research leading to these results has received funding from the
# European Commission's Seventh Framework Programme (FP7/2007-13)
# under grant agreement no 257386.

# Copyright 2012 Yahya Al-Hazmi, TU Berlin
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#

#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License
 
 
# this script fetches resource monitoring information from Zabbix-Server
# through Zabbix-API
#
# To run this script you need to install python-argparse "apt-get install python-argparse"
 
from zabbix_api import ZabbixAPI
import sys
import datetime
import time
import argparse
 
def fetch_to_csv(username,password,server,hostname,key,output,datetime1,datetime2,debuglevel):
        zapi = ZabbixAPI(server=server, log_level=debuglevel)
        try:
        zapi.login(username, password)
    except:
            print "zabbix server is not reachable: %s" % (server)
        sys.exit()
        host = zapi.host.get({"filter":{"host":hostname}, "output":"extend"})
    if(len(host)==0):
        print "hostname: %s not found in zabbix server: %s, exit" % (hostname,server)
        sys.exit()
    else:
        hostid=host[0]["hostid"]
    print '*' * 100
    print key
  print '*' * 100
    if(key==""):
        print '*' * 100
        items = zapi.item.get({"filter":{"hostid":hostid} , "output":"extend"})
        if(len(items)==0):
            print "there is no item in hostname: %s, exit" % (hostname)
                        sys.exit()
        dict={}
        for item in items:
            dict[str(item['itemid'])]=item['key_']
        if (output == ''):
                        output=hostname+".csv"
        f = open(output, 'w')
        str1="#key;timestamp;value\n"
 
        if (datetime1=='' and datetime2==''):
            for itemid in items:
                itemidNr=itemid["itemid"]
                            str1=str1+itemid["key_"]+";"+itemid["lastclock"]+";"+itemid["lastvalue"]+"\n"
            f.write(str1)
                        print "Only the last value from each key has been fetched, specify t1 or t1 and t2 to fetch more data"
            f.close()
        elif (datetime1!='' and datetime2==''):
            try:
                            d1=datetime.datetime.strptime(datetime1,'%Y-%m-%d %H:%M:%S')
            except:
                print "time data %s does not match format Y-m-d H:M:S, exit" % (datetime1)
                sys.exit()
                        timestamp1=time.mktime(d1.timetuple())
                        timestamp2=int(round(time.time()))
                    inc=0
            history = zapi.history.get({"hostids":[hostid,],"time_from":timestamp1,"time_till":timestamp2, "output":"extend" })
                    for h in history:
                            str1=str1+dict[h["itemid"]]+";"+h["clock"]+";"+h["value"]+"\n"
                            inc=inc+1
                        f.write(str1)
                        f.close()
                        print str(inc) +" records has been fetched and saved into: " + output
        elif (datetime1=='' and datetime2!=''):
            for itemid in items:
                                itemidNr=itemid["itemid"]
                                str1=str1+itemid["key_"]+";"+itemid["lastclock"]+";"+itemid["lastvalue"]+"\n"
                        f.write(str1)
                        print "Only the last value from each key has been fetched, specify t1 or t1 and t2 to fetch more data"
                        f.close()
        else:
            try:
                            d1=datetime.datetime.strptime(datetime1,'%Y-%m-%d %H:%M:%S')
                        except:
                                print "time data %s does not match format Y-m-d H:M:S, exit" % (datetime1)
                                sys.exit()
            try:
                            d2=datetime.datetime.strptime(datetime2,'%Y-%m-%d %H:%M:%S')
                        except:
                                print "time data %s does not match format Y-m-d H:M:S, exit" % (datetime2)
                                sys.exit()
                        timestamp1=time.mktime(d1.timetuple())
                        timestamp2=time.mktime(d2.timetuple())
            inc=0
                        history = zapi.history.get({"hostids":[hostid,],"time_from":timestamp1,"time_till":timestamp2, "output":"extend" })
                        for h in history:
                                str1=str1+dict[h["itemid"]]+";"+h["clock"]+";"+h["value"]+"\n"
                                inc=inc+1
                        f.write(str1)
                        f.close()
                        print str(inc) +" records has been fetched and saved into: " + output
    else:
        #print "key is: %s" %(key)
            itemid = zapi.item.get({"filter":{"key_":key, "hostid":hostid} , "output":"extend"})
        if(len(itemid)==0):
            print "item key: %s not found in hostname: %s" % (key,hostname)
            sys.exit()
            itemidNr=itemid[0]["itemid"]
            if (output == ''):
                    output=hostname+".csv"
            f = open(output, 'w')
            str1="#key;timestamp;value\n"
       
            if (datetime1=='' and datetime2==''):
                    str1=str1+key+";"+itemid[0]["lastclock"]+";"+itemid[0]["lastvalue"]+"\n"
                    #f.write(str1)
            f.write(str1)
            f.close()
                print "Only the last value has been fetched, specify t1 or t1 and t2 to fetch more data"
            elif (datetime1!='' and datetime2==''):
                    d1=datetime.datetime.strptime(datetime1,'%Y-%m-%d %H:%M:%S')
                    timestamp1=time.mktime(d1.timetuple())
                    timestamp2=int(round(time.time()))
                history = zapi.history.get({"history":itemid[0]["value_type"],"time_from":timestamp1,"time_till":timestamp2, "itemids":[itemidNr,], "output":"extend" })
                    inc=0
                    for h in history:
                        str1 = str1 + key + ";" + h["clock"] +";"+h["value"] + "\n"
                        inc=inc+1
            f.write(str1)
                        f.close()
                    print str(inc) +" records has been fetched and saved into: " + output
            elif (datetime1=='' and datetime2!=''):
                str1=str1+key+";"+itemid[0]["lastclock"]+";"+itemid[0]["lastvalue"]+"\n"
            f.write(str1)
                        f.close()
                print "Only the last value has been fetched, specify t1 or t1 and t2 to fetch more data"
        else:
                    d1=datetime.datetime.strptime(datetime1,'%Y-%m-%d %H:%M:%S')
                    d2=datetime.datetime.strptime(datetime2,'%Y-%m-%d %H:%M:%S')
                    timestamp1=time.mktime(d1.timetuple())
                    timestamp2=time.mktime(d2.timetuple())
                    history = zapi.history.get({"history":itemid[0]["value_type"],"time_from":timestamp1,"time_till":timestamp2, "itemids":[itemidNr,], "output":"extend" })
                    inc=0
                    for h in history:
                        str1 = str1 + key + ";" + h["clock"] +";"+h["value"] + "\n"
                        inc=inc+1
                    print str(inc) +" records has been fetched and saved into: " + output
                f.write(str1)
                        f.close()
       
parser = argparse.ArgumentParser(description='Fetch history from aggregator and save it into CSV file')
parser.add_argument('-s', dest='server_IP', required=True,
                  help='aggregator IP address')
parser.add_argument('-n', dest='hostname', required=True,
                  help='name of the monitored host')
parser.add_argument('-k', dest='key',default='',
                  help='zabbix item key, if not specified the script will fetch all keys for the specified hostname')
parser.add_argument('-u', dest='username', default='Admin',
                  help='zabbix username, default Admin')
parser.add_argument('-p', dest='password', default='zabbix',
                  help='zabbix password')
parser.add_argument('-o', dest='output', default='',
                  help='output file name, default hostname.csv')
parser.add_argument('-t1', dest='datetime1', default='',
                  help='begin date-time, use this pattern \'2011-11-08 14:49:43\' if only t1 specified then time period will be t1-now ')
parser.add_argument('-t2', dest='datetime2', default='',
                  help='end date-time, use this pattern \'2011-11-08 14:49:43\'')
parser.add_argument('-v', dest='debuglevel', default=0, type=int,
                  help='log level, default 0')
args = parser.parse_args()
 
fetch_to_csv(args.username, args.password, "http://"+args.server_IP+"/zabbix", args.hostname, args.key, args.output, args.datetime1,args.datetime2,args.debuglevel)

二:撰写通过key获取一周内的数据

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/ffe942d2ed4265818c07ce4dce4f88b7.html