Zabbix与RRDtool绘图篇之用ZabbixAPI取监控数据

一起来看一个Zabbix与RRDtool绘图篇之用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

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，结果也是由字典组成的列表。

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。

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

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