Zabbix与RRDtool绘图篇(1)_用ZabbixAPI取监控数据

经过一个星期的死磕,Zabbix取数据和RRDtool绘图都弄清楚了,做第一运维平台的时候绘图取数据是直接从Zabbix的数据库取的,显得有点笨拙,不过借此也了解了Zabbix数据库结构还是有不少的收获。

学习Zabbix的API官方文档少不了,官方文档地址链接https://www.zabbix.com/documentation/ 大家选择对应的版本就好了,不过2.0版本的API手册位置有点特别开始我还以为没有,后来找到了如下https://www.zabbix.com/documentation/2.0/manual/appendix/api/api   用ZabbixAPI取监控数据的思路大致是这样的,先获取所有监控的主机,再遍历每台主机获取每台主机的所有图形,最后获取每张图形每个监控对象(item)的最新的监控数据或者一定时间范围的数据。   下面按照上面的思路就一段一段的贴出我的程序代码:

1、登录Zabbix获取通信token

#!/usr/bin/env python
#coding=utf-8
import json
import urllib2
import sys
##########################
class Zabbix:
    def __init__(self):
        self.url = "http://xxx.xxx.xxx.xxx:xxxxx/api_jsonrpc.php"
        self.header = {"Content-Type": "application/json"}
        self.authID = self.user_login()
    def user_login(self):
        data = json.dumps({
                            "jsonrpc": "2.0",
                            "method": "user.login",
                            "params": {"user": "用户名",   "password": "密码"},
                            "id": 0})
        request = urllib2.Request(self.url,data)
        for key in self.header:
            request.add_header(key,self.header[key])
        try:
            result = urllib2.urlopen(request)
        except URLError as e:
            print "Auth Failed, Please Check Your Name And Password:",e.code
        else:
            response = json.loads(result.read())
            result.close()
            authID = response['result']
            return authID
    ##################通用请求处理函数####################
    def get_data(self,data,hostip=""):
        request = urllib2.Request(self.url,data)
        for key in self.header:
            request.add_header(key,self.header[key])
        try:
            result = urllib2.urlopen(request)
        except URLError as e:
            if hasattr(e, 'reason'):
                print 'We failed to reach a server.'
                print 'Reason: ', e.reason
            elif hasattr(e, 'code'):
                print 'The server could not fulfill the request.'
                print 'Error code: ', e.code
                return 0
        else:
            response = json.loads(result.read())
            result.close()
            return response

2、获取所有主机

#####################################################################
    #获取所有主机和对应的hostid
    def hostsid_get(self):
        data = json.dumps({
                            "jsonrpc": "2.0",
                            "method": "host.get",
                            "params": { "output":["hostid","status","host"]},
                            "auth": self.authID,
                            "id": 1})
        res = self.get_data(data)['result']
        #可以返回完整信息
        #return res
        hostsid = []
        if (res != 0) and (len(res) != 0):
            for host in res:
                if host['status'] == '1':
                    hostsid.append({host['host']:host['hostid']})
                elif host['status'] == '0':
                    hostsid.append({host['host']:host['hostid']})
                else:
                    pass
        return hostsid

返回的结果是一个列表,每个元素是一个字典,字典的key代表主机名,value代表hostid 

zabbixget01

3、获取每台主机的每张图形

###################################################################
    #查找一台主机的所有图形和图形id
    def hostgraph_get(self, hostname):
        data = json.dumps({
                            "jsonrpc": "2.0",
                            "method": "host.get",
                            "params": { "selectGraphs": ["graphid","name"],
                                        "filter": {"host": hostname}},
                            "auth": self.authID,
                            "id": 1})
        res = self.get_data(data)['result']
        #可以返回完整信息rs,含有hostid
        return res[0]['graphs']

注意传入的参数是主机名而不是主机id,结果也是由字典组成的列表。

zabbixget02

4、获取每张图的监控对象item

#可以返回完整信息rs,含有hostid
    tmp = res[0]['items']
    items = []
    for value in tmp:
        if '$' in value['name']:
            name0 = value['key_'].split('[')[1].split(']')[0].replace(',', '')
            name1 = value['name'].split()
            if 'CPU' in name1:
                name1.pop(-2)
                name1.insert(1,name0)
            else:
                name1.pop()
                name1.append(name0)
            name = ' '.join(name1)
            tmpitems = {'itemid':value['itemid'],'delay':value['delay'],'units':value['units'],'name':name,'value_type':value['value_type'],'lastclock':value['lastclock'],'lastvalue':value['lastvalue']}
        else:
            tmpitems = {'itemid':value['itemid'],'delay':value['delay'],'units':value['units'],'name':value['name'],'value_type':value['value_type'],'lastclock':value['lastclock'],'lastvalue':value['lastvalue']}
        items.append(tmpitems)
    return items

返回的数据已经包含了最新的一次监控数据的值和取值的时间戳,如果只需要取最新的监控数据,到这里其实就可以了,记得这次传入的参数是graphid。 

zabbixget03

5、根据itemid取得更多的监控数据

下面是取10条监控数据,可以任意更改参数获取更多的数据,全凭自己所需了。

################################################################
    #获取历史数据,history必须赋值正确的类型0,1,2,3,4 float,string,log,integer,text
    def history_get(self, itemid, i):
        data = json.dumps({
                            "jsonrpc": "2.0",
                            "method": "history.get",
                            "params": { "output": "extend",
                                        "history": i,
                                        "itemids": itemid,
                                        "sortfield": "clock",
                                        "sortorder": "DESC",
                                        "limit": 10},
                            "auth": self.authID,
                            "id": 1})
        res = self.get_data(data)['result']
        return res

zabbixget04

上面的所有代码加起来就是一个Zabbix取数据的类。取出来的数据可以用RRDtool绘图或做其它用途了。




本站的发展离不开您的资助,金额随意,欢迎来赏!

You can donate through PayPal.
My paypal id: itybku@139.com
Paypal page: https://www.paypal.me/361way

分类: 开源软件 标签: ,
  1. 本文目前尚无任何评论.
  1. 本文目前尚无任何 trackbacks 和 pingbacks.