备案控制台
开发者社区 开发与运维 文章 正文

python调用zabbix api接口实时展示数据

2017-11-07 4922
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

    近日公司准备自已做一个运维管理平台，其中的监控部分，打算调用zabbix api接口来进行展示。

经过思考之后，计划获取如下内容：

    1、  获得认证密钥

    2、  获取zabbix所有的主机组

    3、  获取单个组下的所有主机

    4、  获取某个主机下的所有监控项

    5、  获取某个监控项的历史数据

    6、  获取某个监控项的最新数据

 

计划最后展示框架如下内容（这只是值方面，其它的会再加）：

主机组1 ----主机名1---监控项1----当前值

                  ---监控项2----当前值

       ----主机名2----监控项1----当前值

                 ----监控项2----当前值

主机组2 ----主机名3---监控项1----当前值

                  ---监控项2----当前值

       ----主机名4----监控项1----当前值

                  ----监控项2----当前值

 

进入正题

1.     user.login方法获取zabbix server的认证结果

官方地址：https://www.zabbix.com/documentation/2.2/manual/api/reference/user/login

python脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
[root@yang python] # cat auth.py
#!/usr/bin/env python2.7
#coding=utf-8
import  json
import  urllib2
# based url and required header
url  =  "http://1.1.1.1/zabbix/api_jsonrpc.php"
header  =  { "Content-Type" : "application/json" }
# auth user and password
data  =  json.dumps(
{
    "jsonrpc" :  "2.0" ,
    "method" :  "user.login" ,
    "params" : {
    "user" :  "Admin" ,
    "password" :  "zabbix"
},
"id" :  0
})
# create request object
request  =  urllib2.Request(url,data)
for  key  in  header:
    request.add_header(key,header[key])
# auth and get authid
try :
    result  =  urllib2.urlopen(request)
except  URLError as e:
    print  "Auth Failed, Please Check Your Name AndPassword:" ,e.code
else :
    response  =  json.loads(result.read())
    result.close()
print "Auth Successful. The Auth ID Is:" ,response[ 'result' ]

python脚本运行结果：

1
2
[root@yang python] # python auth.py
Auth Successful. The Auth  ID  Is: a0b82aae0842c2041386a61945af1180

curl命令：

1
2
3
curl  - i  - X POST  - H  'Content-Type:application/json'  - d '{ "jsonrpc" :
"2.0" , "method" : "user.login" , "params" :{ "user" : "admin" , "password" : "zabbix" }, "auth" :
null, "id" : 0 }' http: / / 1.1 . 1.1 / zabbix / api_jsonrpc.php

curl命令运行结果：

1
{ "jsonrpc" : "2.0" , "result" : "b895ce91ba84fe247e444817c6773cc3" , "id" : 0 }

 

2.     hostgroup.get方法获取所有主机组ID

把认证密钥放到脚本中，每次获取数据时都需要认证。此处是获取zabbix server上的所有主机组名称与ID号。

官方地址：https://www.zabbix.com/documentation/2.2/manual/api/reference/hostgroup/get

python脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
[root@yang python] # catget_hostgroup_list.py
#!/usr/bin/env python2.7
#coding=utf-8
import  json
import  urllib2
# based url and required header
url  =  "http://1.1.1.1/zabbix/api_jsonrpc.php"
header  =  { "Content-Type" : "application/json" }
# request json
data  =  json.dumps(
{
    "jsonrpc" : "2.0" ,
    "method" : "hostgroup.get" ,
    "params" :{
        "output" :[ "groupid" , "name" ],
    },
    "auth" : "3c0e88885a8cf8af9502b5c850b992bd" ,  # theauth id is what auth script returns, remeber it is string
    "id" : 1 ,
})
# create request object
request  =  urllib2.Request(url,data)
for  key  in  header:
    request.add_header(key,header[key])
# get host list
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
else :
    response  =  json.loads(result.read())
    result.close()
    print  "Number Of Hosts: " ,  len (response[ 'result' ])
    #print response
    for  group  in  response[ 'result' ]:
        print  "Group ID:" ,group[ 'groupid' ], "\tGroupName:" ,group[ 'name' ]

python脚本执行结果：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
[root@yang python] # pythonget_hostgroup_list.py
Number Of Hosts:   12
Group  ID :  11     Group Name: DB Schedule
Group  ID :  14     Group Name: DG - WY - KD - Server
Group  ID :  5      Group Name: Discovered hosts
Group  ID :  7      Group Name: Hypervisors
Group  ID :  2      Group Name: Linux servers
Group  ID :  8      Group Name: monitored_linux
Group  ID :  9      Group Name: qsmind
Group  ID :  12     Group Name: qssec
Group  ID :  13     Group Name: switch
Group  ID :  1      Group Name: Templates
Group  ID :  6      Group Name: Virtual machines
Group  ID :  4      Group Name: Zabbix servers

curl命令：

1
curl  - i  - X POST  - H  'Content-Type:application/json'  - d  '{"jsonrpc": "2.0","method":"hostgroup.get","params":{"output":["groupid","name"]},"auth":"11d2b45415d5de6770ce196879dbfcf1","id": 0}'  http: / / 1.1 . 1.1 / zabbix / api_jsonrpc.php

curl执行结果：

1
{ "jsonrpc" : "2.0" , "result" :[{ "groupid" : "11" , "name" : "DBSchedule" },{ "groupid" : "14" , "name" : "DG-WY-KD-Server" },{ "groupid" : "5" , "name" : "Discoveredhosts" },{ "groupid" : "7" , "name" : "Hypervisors" },{ "groupid" : "2" , "name" : "Linuxservers" },{ "groupid" : "8" , "name" : "monitored_linux" },{ "groupid" : "9" , "name" : "qsmind" },{ "groupid" : "12" , "name" : "qssec" },{ "groupid" : "13" , "name" : "switch" },{ "groupid" : "1" , "name" : "Templates" },{ "groupid" : "6" , "name" : "Virtualmachines" },{ "groupid" : "4" , "name" : "Zabbixservers" }], "id" : 0 }

 

3.     host.get方法获取单个主机组下所有的主机ID。

根据标题2中获取到的主机组id，把主机组id填入到下边脚本中，就可以获得该主机组下所有的主机id。

官方地址：https://www.zabbix.com/documentation/2.2/manual/api/reference/host/get

python脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
[root@yang python] # cat get_group_one.py
#!/usr/bin/env python2.7
#coding=utf-8
import  json
import  urllib2
# based url and required header
url  =  "http://1.1.1.1/zabbix/api_jsonrpc.php"
header  =  { "Content-Type" : "application/json" }
# request json
data  =  json.dumps(
{
    "jsonrpc" : "2.0" ,
    "method" : "host.get" ,
    "params" :{
        "output" :[ "hostid" , "name" ],
        "groupids" : "14" ,
    },
    "auth" : "3c0e88885a8cf8af9502b5c850b992bd" ,  # theauth id is what auth script returns, remeber it is string
    "id" : 1 ,
})
# create request object
request  =  urllib2.Request(url,data)
for  key  in  header:
    request.add_header(key,header[key])
# get host list
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
else :
    response  =  json.loads(result.read())
    result.close()
    print  "Number Of Hosts: " ,  len (response[ 'result' ])
    for  host  in  response[ 'result' ]:
        print  "Host ID:" ,host[ 'hostid' ], "HostName:" ,host[ 'name' ]

python脚本执行结果：

1
2
3
4
5
6
[root@yang python] # pythonget_group_one.py  
Number Of Hosts:   4
Host  ID :  10146  Host Name: DG - WY - KD - 3F3B - 00
Host  ID :  10147  Host Name: DG - WY - KD - 3F3B - 01
Host  ID :  10148  Host Name: DG - WY - KD - 3F3B - 02
Host  ID :  10149  Host Name: DG - WY - KD - 3F3B - 03

curl命令：

1
2
curl  - i  - X POST  - H 'Content-Type: application/json'  - d  '{"jsonrpc":"2.0","method":"host.get","params":{"output":["hostid","name"],"groupids":"14"},"auth":"11d2b45415d5de6770ce196879dbfcf1","id": 0}' 
http: / / 1.1 . 1.1 / zabbix / api_jsonrpc.php

curl命令执行结果：

1
{ "jsonrpc" : "2.0" , "result" :[{ "hostid" : "10146" , "name" : "DG-WY-KD-3F3B-00" },{ "hostid" : "10147" , "name" : "DG-WY-KD-3F3B-01" },{ "hostid" : "10148" , "name" : "DG-WY-KD-3F3B-02" },{ "hostid" : "10149" , "name" : "DG-WY-KD-3F3B-03" }], "id" : 0 }

 

4.     itemsid.get方法获取单个主机下所有的监控项ID

根据标题3中获取到的所有主机id与名称，找到你想要获取的主机id，获取它下面的所有items。

官方地址：https://www.zabbix.com/documentation/2.2/manual/api/reference/item

python脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
[root@yang python] # cat get_items.py
#!/usr/bin/env python2.7
#coding=utf-8
import  json
import  urllib2
# based url and required header
url  =  "http://1.1.1.1/zabbix/api_jsonrpc.php"
header  =  { "Content-Type" : "application/json" }
# request json
data  =  json.dumps(
{
    "jsonrpc" : "2.0" ,
    "method" : "item.get" ,
    "params" :{
        "output" :[ "itemids" , "key_" ],
        "hostids" : "10146" ,
    },
    "auth" : "3c0e88885a8cf8af9502b5c850b992bd" ,  # theauth id is what auth script returns, remeber it is string
    "id" : 1 ,
})
# create request object
request  =  urllib2.Request(url,data)
for  key  in  header:
    request.add_header(key,header[key])
# get host list
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
else :
    response  =  json.loads(result.read())
    result.close()
    print  "Number Of Hosts: " ,  len (response[ 'result' ])
    for  host  in  response[ 'result' ]:
        print  host
        #print "Host ID:",host['hostid'],"HostName:",host['name']

python脚本运行结果：

1
2
3
4
5
6
7
8
9
10
[root@yang python] # python get_items.py
Number Of Hosts:   54
{u 'itemid' : u '24986' , u 'key_' :u 'agent.hostname' }
{u 'itemid' : u '24987' , u 'key_' :u 'agent.ping' }
{u 'itemid' : u '24988' , u 'key_' :u 'agent.version' }
{u 'itemid' : u '24989' , u 'key_' :u 'kernel.maxfiles' }
{u 'itemid' : u '24990' , u 'key_' :u 'kernel.maxproc' }
{u 'itemid' : u '25157' , u 'key_' :u 'net.if.in[eth0]' }
{u 'itemid' : u '25158' , u 'key_' :u 'net.if.in[eth1]' }
… …

curl命令：

1
2
curl  - i  - X POST  - H  'Content-Type:application/json'  - d  '{"jsonrpc":"2.0","method":"item.get","params":{"output":"itemids","hostids":"10146","search":{"key_":"net.if.out[eth2]"}},"auth":"11d2b45415d5de6770ce196879dbfcf1","id": 0}'  http: / / 1.1 . 1.1 / zabbix / api_jsonrpc.php
#此处加上了单个key的名称

curl命令执行结果：

1
{ "jsonrpc" : "2.0" , "result" :[{ "itemid" : "25154" }], "id" : 0 }

5.     history.get方法获取单个监控项的历史数据

根据第4项的获取到的所有items id的值，找到想要监控的那项，获取它的历史数据。

官方地址：https://www.zabbix.com/documentation/2.2/manual/api/reference/history/get

python脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
[root@yang python] # catget_items_history.py
#!/usr/bin/env python2.7
#coding=utf-8
import  json
import  urllib2
# based url and required header
url  =  "http://1.1.1.1/zabbix/api_jsonrpc.php"
header  =  { "Content-Type" : "application/json" }
# request json
data  =  json.dumps(
{
    "jsonrpc" : "2.0" ,
    "method" : "history.get" ,
    "params" :{
        "output" : "extend" ,
        "history" : 3 ,
        "itemids" : "25159" ,
        "limit" : 10
    },
    "auth" : "3c0e88885a8cf8af9502b5c850b992bd" ,  # theauth id is what auth script returns, remeber it is string
    "id" : 1 ,
})
# create request object
request  =  urllib2.Request(url,data)
for  key  in  header:
    request.add_header(key,header[key])
# get host list
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
else :
    response  =  json.loads(result.read())
    result.close()
    print  "Number Of Hosts: " ,  len (response[ 'result' ])
    for  host  in  response[ 'result' ]:
        print  host
        #print "Host ID:",host['hostid'],"HostName:",host['name']

python脚本执行结果：

1
2
3
4
5
6
7
8
9
10
11
12
[root@yang python] # pythonget_items_history.py
Number Of Hosts:   10
{u 'itemid' : u '25159' , u 'ns' : u '420722133' ,u 'value' : u '3008' , u 'clock' : u '1410744079' }
{u 'itemid' : u '25159' , u 'ns' : u '480606614' ,u 'value' : u '5720' , u 'clock' : u '1410744139' }
{u 'itemid' : u '25159' , u 'ns' : u '40905600' ,u 'value' : u '6144' , u 'clock' : u '1410744200' }
{u 'itemid' : u '25159' , u 'ns' : u '175337062' ,u 'value' : u '2960' , u 'clock' : u '1410744259' }
{u 'itemid' : u '25159' , u 'ns' : u '202705084' ,u 'value' : u '3032' , u 'clock' : u '1410744319' }
{u 'itemid' : u '25159' , u 'ns' : u '263158421' ,u 'value' : u '2864' , u 'clock' : u '1410744379' }
{u 'itemid' : u '25159' , u 'ns' : u '702285081' ,u 'value' : u '7600' , u 'clock' : u '1410744439' }
{u 'itemid' : u '25159' , u 'ns' : u '231191890' ,u 'value' : u '3864' , u 'clock' : u '1410744499' }
{u 'itemid' : u '25159' , u 'ns' : u '468566742' ,u 'value' : u '3112' , u 'clock' : u '1410744559' }
{u 'itemid' : u '25159' , u 'ns' : u '421679098' ,u 'value' : u '2952' , u 'clock' : u '1410744619' }

curl命令：

1
curl  - i  - X POST  - H  'Content-Type:application/json'  - d  '{"jsonrpc":"2.0","method":"history.get","params":{"history":3,"itemids":"25154","output":"extend","limit":10},"auth":"11d2b45415d5de6770ce196879dbfcf1","id": 0}'  http: / / 1.1 . 1.1 / zabbix / api_jsonrpc.php

curl命令运行结果：

1
{ "jsonrpc" : "2.0" , "result" :[{ "itemid" : "25154" , "clock" : "1410744134" , "value" : "4840" , "ns" : "375754276" },{ "itemid" : "25154" , "clock" : "1410744314" , "value" : "5408" , "ns" : "839852515" },{ "itemid" : "25154" , "clock" : "1410744374" , "value" : "7040" , "ns" : "964558609" },{ "itemid" : "25154" , "clock" : "1410744554" , "value" : "4072" , "ns" : "943177771" },{ "itemid" : "25154" , "clock" : "1410744614" , "value" : "8696" , "ns" : "995289716" },{ "itemid" : "25154" , "clock" : "1410744674" , "value" : "6144" , "ns" : "992462863" },{ "itemid" : "25154" , "clock" : "1410744734" , "value" : "6472" , "ns" : "152634327" },{ "itemid" : "25154" , "clock" : "1410744794" , "value" : "4312" , "ns" : "479599424" },{ "itemid" : "25154" , "clock" : "1410744854" , "value" : "4456" , "ns" : "263314898" },{ "itemid" : "25154" , "clock" : "1410744914" , "value" : "8656" , "ns" : "840460009" }], "id" : 0 }

 

6.     history.get方法获取单个监控项最后的值

只需把上个脚本中或curl中的limit参数改为1就可。



此时监控项的数据已拿到了，接下来的把它传给前台展示就行了。





     本文转自杨云1028 51CTO博客，原文链接：http://blog.51cto.com/yangrong/1559123，如需转载请自行联系原作者




文章标签：
监控
Python
数据格式
JSON
API
关键词：
Python数据
Python接口
API接口
API数据
API python
技术小胖子
目录
相关文章
东方睿赢
|
1天前
|
XML 前端开发 数据格式
BeautifulSoup 是一个 Python 库，用于从 HTML 和 XML 文件中提取数据
BeautifulSoup 是 Python 的一个库，用于解析 HTML 和 XML 文件，即使在格式不规范的情况下也能有效工作。通过创建 BeautifulSoup 对象并使用方法如 find_all 和 get，可以方便地提取和查找文档中的信息。以下是一段示例代码，展示如何安装库、解析 HTML 数据以及打印段落、链接和特定类名的元素。BeautifulSoup 还支持更复杂的查询和文档修改功能。
东方睿赢
7 1
然然学长
|
3天前
|
存储 JSON 数据挖掘
python序列化和结构化数据详解
python序列化和结构化数据详解
然然学长
11 0
库库的里昂
|
3天前
|
数据采集 数据可视化 数据挖掘
Python 与 PySpark数据分析实战指南：解锁数据洞见
Python 与 PySpark数据分析实战指南：解锁数据洞见
库库的里昂
14 2
游客762btuqu5wybw666
|
3天前
|
数据采集 数据处理 开发者
Python 中的数据处理技巧：高效数据操作的艺术
Python 在数据处理方面表现卓越，为开发者提供了丰富的工具和库以简化数据操作。在本文中，我们将探讨 Python 中数据处理的一些技巧，包括数据清洗、数据转换以及优化数据操作的最佳实践。通过掌握这些技巧，您可以在 Python 中更加高效地处理和分析数据。
游客762btuqu5wybw666
13 1
Onebound19970109110
|
4天前
|
监控 PHP Python
1688快速获取整店铺列表 采集接口php Python
在电子商务的浪潮中，1688平台作为中国领先的批发交易平台，为广大商家提供了一个展示和销售商品的广阔舞台；然而，要在众多店铺中脱颖而出，快速获取商品列表并进行有效营销是关键。
Onebound19970109110
11 0
拓端数据部落
|
5天前
|
机器学习/深度学习 自然语言处理 算法
Python遗传算法GA对长短期记忆LSTM深度学习模型超参数调优分析司机数据|附数据代码
Python遗传算法GA对长短期记忆LSTM深度学习模型超参数调优分析司机数据|附数据代码
拓端数据部落
24 0
sumith
|
5天前
|
开发者 索引 Python
Python中调整两列数据顺序的多种方式
Python中调整两列数据顺序的多种方式
sumith
24 0
sumith
|
5天前
|
SQL API 数据库
在Python中获取筛选后的SQL数据行数
在Python中获取筛选后的SQL数据行数
sumith
12 1
科技小能手
|
Web App开发 监控 测试技术
python实现zabbix批量监控WEB网站和批量监控主机端口
科技小能手
2749 0
东方睿赢
|
2天前
|
JSON 数据格式 开发者
pip和requests在Python编程中各自扮演着不同的角色
`pip`是Python的包管理器，用于安装、升级和管理PyPI上的包；`requests`是一个HTTP库，简化了HTTP通信，支持各种HTTP请求类型及数据交互。两者在Python环境中分别负责包管理和网络请求。
东方睿赢
13 5

热门文章

最新文章

  • 1
    阿里云 MaxCompute MaxFrame 开启免费邀测，统一 Python 开发生态
  • 2
    使用Python实现DBSCAN聚类算法
  • 3
    Python与NoSQL数据库（MongoDB、Redis等）面试问答
  • 4
    流畅的 Python 第二版（GPT 重译）（一）(1)
  • 5
    【Python】python天气数据抓取与数据分析（源码+论文）【独一无二】
  • 6
    流畅的 Python 第二版（GPT 重译）（十一）(1)
  • 7
    【python】Python航空公司客户价值数据分析（代码+论文）【独一无二】
  • 8
    Python 数据分析（PYDA）第三版（三）（1）
  • 9
    Python速成篇（基础语法）上
  • 10
    流畅的 Python 第二版（GPT 重译）（九）(2)
  • 1
    从API到Agent：万字长文洞悉LangChain工程化设计
    119
  • 2
    如何在Linux使用docker部署Swagger Editor并实现无公网IP远程协同编辑API文档
    53
  • 3
    虾皮Shopee根据ID取商品详情API
    37
  • 4
    谷歌发布MediaPipe LLM Inference API，28亿参数模型本地跑
    94
  • 5
    【微信小程序】-- 使用 npm 包 - API Promise化（四十二）
    38
  • 6
    阿里云BssOpenAPI是一个基于阿里云开放API的服务
    156
  • 7
    零一万物API正式上线：支持输入30万汉字
    28
  • 8
    如何高效接入 Flink： Connecter / Catalog API 核心设计与社区进展
    299
  • 9
    DataWorks常见问题之使用API删除之前的部署文件失败如何解决
    24
  • 10
    短信服务的API秘钥认证如何防止滥用
    15

    • 相关课程

    更多
  • Python爬虫实战
  • Python开发基础入门
  • Python常用数据科学库
  • Python网络爬虫实战
  • Python完全自学手册图文教程
  • Python基础快速入门实战教程

    • 相关电子书

    更多
  • From Python Scikit-Learn to Sc
  • Data Pre-Processing in Python:
  • 双剑合璧-Python和大数据计算平台的结合

    • 相关实验场景

    更多
  • 快速体验智能体API应用
  • 用Python画圣诞树
  • 使用Python完成RDS数据开发及分析
  • Python选择及循环结构
  • 云端Python及基本操作
  • ROS模板参数动态展示

    • 推荐镜像

    更多
  • zabbix
  • mariadb
  • mysql
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）