Python 调用 zabbix api的方法示例
前提准备：
1.使用pythonrequests模块
2.了解json
3.zabbixapi的具体调用建议先浏览一下官网
先上代码：
importrequests,json
#
#url一定要正确，IP地址换成自己zabbix服务器的
zbx_url="http://192.168.60.130:3080/zabbix/api_jsonrpc.php"
#在post请求头部必须要有'Content-Type':'application/json-rpc'
headers={'Content-Type':'application/json-rpc'}
#传递json数据到api;登录
login={
"jsonrpc":"2.0",
"method":"user.login",
"params":{
"user":"Admin",
"password":"zabbix"
},
"id":1
}
#首次登陆不用在json字段中写auth，否则会有相关的报错
#将数据发送到api
ret=requests.post(zbx_url,data=json.dumps(login),headers=headers)
#对结果进行序列化
ret=ret.json()
auth=ret['result']
#获取问题主机json
data={
"jsonrpc":"2.0",
"method":"trigger.get",
"params":{
#output表示输出结果包含参数有哪些
"output":[
"triggerid",
"description",
"status",
"value",
"priority",
"lastchange",
"recovery_mode",
"hosts",
"state",
],
"selectHosts":"hosts",#需包含主机ID信息，以便于根据主机ID查询主机信息
"selectItems":"items",
"filter":{
#筛选条件
"value":1,#value值为1表示有问题
"status":0#status为0表示已启用的trigger
},
},
"auth":auth,#这里的auth就是登录后获取的
'id':'1'#这个id可以随意
}
#将查询数据发送到zabbix-server
ret=requests.post(zbx_url,data=json.dumps(data),headers=headers)
respone_result=ret.json()['result']#对结果进行json序列化
print(respone_result)
下面简单介绍一下上诉代码：
要调用zabbixapi获取数据，首先要获得auth这一串字符用户后续的内容获取，auth可以看做是一种你与zabbix-server之间的"暗号"；
登录的json内容之所以这样写是zabbix官方规定的，json字符串里面千万不能使用tab键。
login={
"jsonrpc":"2.0",
"method":"user.login",
"params":{
"user":"Admin",#根据自己的情况填
"password":"zabbix"#根据自己的条件填写
},
"id":1
}
获取问题主机的json字符串建议先浏览一下官网的说明，要强调的是output和filter这两个key，output就是zabbixapi返回来的内容，filter相当于是过滤条件：
"filter":{
#筛选条件
"value":1,#value值为1表示有问题
"status":0#status为0表示已启用的trigger
},
上诉代码表示value=1andstatus=0，是一种与关系，很像查数据库表时候的过滤操作。
强烈建议先大概浏览一下官网文档
PS:Python通过ZabbixAPI获得数据的方法
ZabbixAPI查询：https://www.zabbix.com/documentation/2.0/manual/appendix/api/api
importjson,urllib2
fromurllib2importRequest,urlopen,URLError,HTTPError
#urlandurlheader
#zabbix的api地址，用户名，密码，这里修改为自己实际的参数
zabbix_url="http://10.16.2.40/zabbix/api_jsonrpc.php"
zabbix_header={"Content-Type":"application/json"}
zabbix_user="admin"
zabbix_pass="password"
auth_code=""
#authuserandpassword
#用户认证信息的部分，最终的目的是得到一个SESSIONID
#这里是生成一个json格式的数据，用户名和密码
auth_data=json.dumps(
{
"jsonrpc":"2.0",
"method":"user.login",
"params":
{
"user":zabbix_user,
"password":zabbix_pass
},
"id":0
})
#createrequestobject
request=urllib2.Request(zabbix_url,auth_data)
forkeyinzabbix_header:
request.add_header(key,zabbix_header[key])
try:
result=urllib2.urlopen(request)
#对于出错新的处理
exceptHTTPError,e:
print'Theservercouldn\'tfulfilltherequest,Errorcode:',e.code
exceptURLError,e:
print'Wefailedtoreachaserver.Reason:',e.reason
else:
response=json.loads(result.read())
printresponse
result.close()
#判断SESSIONID是否在返回的数据中
if'result'inresponse:
auth_code=response['result']
else:
printresponse['error']['data']
#requestjson
#用得到的SESSIONID去通过验证，获取主机的信息（用http.get方法）
iflen(auth_code)<>0:
host_list=[]
get_host_data=json.dumps(
{
"jsonrpc":"2.0",
"method":"host.get",
"params":{
"output":"extend",
},
"auth":auth_code,
"id":1,
})
#createrequestobject
request=urllib2.Request(zabbix_url,get_host_data)
forkeyinzabbix_header:
request.add_header(key,zabbix_header[key])
#gethostlist
try:
result=urllib2.urlopen(request)
exceptURLErrorase:
ifhasattr(e,'reason'):
print'Wefailedtoreachaserver.'
print'Reason:',e.reason
elifhasattr(e,'code'):
print'Theservercouldnotfulfilltherequest.'
print'Errorcode:',e.code
else:
response=json.loads(result.read())
result.close()
#将所有的主机信息显示出来
forrinresponse['result']:
#printr['hostid'],r['host']
host_list.append(r['hostid'])
#显示主机的个数
print"NumberOfHosts:",len(host_list)
#返回所有hostid==10251的主机，并只查询name包含“CPUUsage”字段的item，并按照name排序
get_item_data=json.dumps({
"jsonrpc":"2.0",
"method":"item.get",
"params":{
"output":"extend",
"hostids":"10251"
"search":{
#"key_":'perf_counter[\ProcessorInformation(_Total)\%ProcessorTime]'
"name":"CPUUsage"
},
"sortfield":"name"
},
"auth":auth_code,
"id":1
})
request=urllib2.Request(zabbix_url,get_item_data)
forkeyinzabbix_header:
request.add_header(key,zabbix_header[key])
result=urllib2.urlopen(request)
try:
result=urllib2.urlopen(request)
response=json.loads(result.read())
forrinresponse['result']:
printr['itemid'],r['hostid']
result.close()
except:
pass
#通过hostid获取相应的graphid
get_graph_data=json.dumps({
"jsonrpc":"2.0",
"method":"graphitem.get",
"params":{
"output":"extend",
"expandData":1,
"itemids":"33712"
},
"auth":auth_code,
"id":1
})
request=urllib2.Request(zabbix_url,get_graph_data)
forkeyinzabbix_header:
request.add_header(key,zabbix_header[key])
result=urllib2.urlopen(request)
try:
result=urllib2.urlopen(request)
response=json.loads(result.read())
forrinresponse['result']:
printr['itemid'],r['graphid']
result.close()
except:
pass
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。