Explication détaillée de l'utilisation de python3-zabbixapi-Tutoriel Python-php.cn

Explication détaillée de l'utilisation de python3-zabbixapi

高洛峰

Libérer： 2017-03-10 18:45:20

original

1437 Les gens l'ont consulté

Cet article explique en détail l'utilisation de python3-zabbixapi

Quelques cas de python3 utilisant l'api zabbix. . Plus précisément, vous pouvez accéder au site officiel de zabbix pour trouver l'excuse de l'API et simplement la remplacer.

#!/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)

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!