Detailed explanation of the use of python3-zabbixapi-Python Tutorial-php.cn

Detailed explanation of the use of python3-zabbixapi

高洛峰

Release： 2017-03-10 18:45:20

Original

1359 people have browsed it

This article explains in detail the use of python3-zabbixapi

Some cases of python3 using zabbix api. . Specifically, you can go to the zabbix official website to find the API excuse and just replace it.

#!/usr/bin/env python
# -*- coding: utf-8 -*-
 
import urllib.request
import json
import re
 
url = &#39;http://xxxxxxxxxxxxxxxx/api_jsonrpc.php&#39;
username = &#39;xxxxxxxxxxxxxxx&#39;
password = &#39;xxxxxx&#39;
 
 
# 登陆
def requestJson(url, values):
    data = json.dumps(values).encode(&#39;utf-8&#39;)
    req = urllib.request.Request(url, data, {&#39;Content-Type&#39;: &#39;application/json-rpc&#39;})
    response = urllib.request.urlopen(req, data)
    a = response.read().decode(encoding=&#39;utf-8&#39;)
    output = json.loads(a)
    #    print output
    try:
        message = output[&#39;result&#39;]
    except:
        message = output[&#39;error&#39;][&#39;data&#39;]
        print(message)
        quit()
 
    return output[&#39;result&#39;]
 
 
##登陆的API
def authenticate(url, username, password):
    values = {&#39;jsonrpc&#39;: &#39;2.0&#39;,
              &#39;method&#39;: &#39;user.login&#39;,
              &#39;params&#39;: {
                  &#39;user&#39;: username,
                  &#39;password&#39;: password
              },
              &#39;id&#39;: &#39;0&#39;
              }
    idvalue = requestJson(url, values)
    return idvalue
 
 
# auth的值
auth = authenticate(url, username, password)
 
 
##查询组ID {&#39;groupid&#39;: &#39;8&#39;, &#39;name&#39;: &#39;Switch&#39;}
def groups(auth):
    values = {
        "jsonrpc": "2.0",
        "method": "hostgroup.get",
        "params": {
            "output": ["groupid", "name"],
        },
        &#39;auth&#39;: auth,
        &#39;id&#39;: &#39;1&#39;
    }
    output = requestJson(url, values)
    return output
 
 
# b = groups(auth)
# print(b)
 
##查询主机  {&#39;hostid&#39;: &#39;10108&#39;,
def hosts(auth):
    values = {
        "jsonrpc": "2.0",
        "method": "host.get",
        "params": {
            "output": ["groupid", "name"],
            "groupids": "8",
        },
        &#39;auth&#39;: auth,
        &#39;id&#39;: &#39;1&#39;
    }
    output = requestJson(url, values)
    return output
 
 
host = hosts(auth)
host1 = []
host2 = []
for i in range(len(host)):
    host1.append(host[i][&#39;name&#39;])
    host2.append(host[i][&#39;hostid&#39;])
 
host3 = dict(zip(host1, host2))
 
 
##查询主机项目 {&#39;key_&#39;: &#39;xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx&#39;, &#39;itemid&#39;: &#39;26399&#39;}
def item(auth):
    values = {
        "jsonrpc": "2.0",
        "method": "item.get",
        "params": {
            "output": ["itemids", "key_"],
            "hostids": "10108",
        },
        &#39;auth&#39;: auth,
        &#39;id&#39;: &#39;1&#39;
    }
    output = requestJson(url, values)
    return output
 
 
# print(item(auth))
 
##查询项目的历史值  &#39;lastvalue&#39;: &#39;-14760.0000&#39;
def his(auth, itemids):
    values = {
        "jsonrpc": "2.0",
        "method": "item.get",
        "params": {
            "output": "extend",
            "history": 0,
            "itemids": itemids,
            "sortfield": "itemid",
            "sortorder": "DESC",
            "limit": 1
        },
        &#39;auth&#39;: auth,
        &#39;id&#39;: &#39;1&#39;
    }
    output = requestJson(url, values)
    return output
 
 
# print(his(auth,26399))
 
##查询触发项目值和监控项目  {&#39;description&#39;: &#39;xxxxxxxxxxxxxxx&#39;, &#39;hostname&#39;: &#39;xxxxxxxxxxxxxxx&#39;, &#39;items&#39;: [{&#39;itemid&#39;: &#39;26399&#39;}], &#39;triggerid&#39;: &#39;17030&#39;}
def trigger(auth, hostid):
    values = {
        "jsonrpc": "2.0",
        "method": "trigger.get",
        "params": {
            "output": [
                "description",
            ],
            "filter": {
                "hostid": hostid,
            },
            "selectItems": "",
            "sortfield": "hostname",
            "sortorder": "DESC"
        },
        &#39;auth&#39;: auth,
        &#39;id&#39;: &#39;1&#39;
    }
    output = requestJson(url, values)
    return output
 
 
 
    ###简单使用案例，可查考，根据触发器查找历史。
        t1 = trigger(auth, host3[msg[&#39;Content&#39;]])
        t2 = []
        t3 = []
        for i in range(len(t1)):
            t5 = t1[i][&#39;items&#39;][0]  ##   &#39;items&#39;: [{&#39;itemid&#39;: &#39;26399&#39;}]
            t6 = his(auth, t5[&#39;itemid&#39;])  ##   his(auth,26399)
            t2.append(t1[i][&#39;description&#39;])  ##监控项目描述
            t3.append(round(float(t6[0][&#39;lastvalue&#39;])) / 1000)  ##项目ID 的值
        t4 = dict(zip(t2, t3))
        t8 = []
        for k in t4:
            t7 = k + ":" + "{}".format(t4[k]) + "db"
            t8.append(t7)
        t9 = "\n".join(t8)

Copy after login

The above is the detailed content of Detailed explanation of the use of python3-zabbixapi. For more information, please follow other related articles on the PHP Chinese website!