利用zabbixapi带入组ID和监控项目键值获取所有主机的值-创新互联

def  chaxun(groupid,items_value):  是自己写的，带入组ID 和 监控项目键值，返回 主机和值的结果。

做了判断，如果这个主机没有想要的监控项目，就去除掉。

#!/usr/bin/env python
#coding=utf-8
import urllib.request
import json
import re

url = 'http://XXXXXXXXXXXXXXXX/api_jsonrpc.php'
username = 'Admin'
password = 'XXXXX'

#登陆
def requestJson(url,values):
    data = json.dumps(values).encode('utf-8')
    req = urllib.request.Request(url, data, {'Content-Type': 'application/json-rpc'})
    response = urllib.request.urlopen(req, data)
    a = response.read().decode(encoding='utf-8')
    output = json.loads(a)
    try:
        message = output['result']
    except:
        message = output['error']['data']
        print(message)
        quit()
    return output['result']


##登陆的API
def authenticate(url, username, password):
    values = {'jsonrpc': '2.0',
              'method': 'user.login',
              'params': {
                  'user': username,
                  'password': password
              },
              'id': '0'
              }
    idvalue = requestJson(url,values)
    return idvalue

auth=authenticate(url,username,password)



##查询组ID {'groupid': '8', 'name': 'Switch'}
def groups(auth):
    values = {
            "jsonrpc":"2.0",
            "method":"hostgroup.get",
              "params":{
                    "output":["groupid","name"],
            },
              'auth': auth,
              'id': '1'
              }
    output = requestJson(url,values)
    return output

##查询主机
def hosts(auth,a):
    values = {
            "jsonrpc":"2.0",
            "method":"host.get",
              "params":{
                    "output":["groupid","name"],
                    "groupids": a,
            },
              'auth': auth,
              'id': '1'
              }
    output = requestJson(url,values)
    return output




##查询主机项目
def items(auth,a):
    values = {
            "jsonrpc":"2.0",
            "method":"item.get",
              "params":{
                  "output": ["itemids", "key_"],
                  "hostids": a,
                  },
              'auth': auth,
              'id': '1'
              }
    output = requestJson(url,values)
    return output

##查询项目的历史值  'lastvalue': '-14760.0000'
def his(auth,itemids):
    values = {
            "jsonrpc":"2.0",
            "method":"item.get",
              "params":{
                    "output": "extend",
                      "history": 0,
                      "itemids": itemids,
                      "sortfield": "itemid",
                      "sortorder": "DESC",
                      "limit": 1
                  },
              'auth': auth,
              'id': '1'
              }
    output = requestJson(url,values)
    return output

##查询触发项目值和监控项目
def trigger(auth):
    values = {
              "jsonrpc":"2.0",
              "method": "trigger.get",
              "params": {
                      "output": [
                        "description",
              ],
              "filter": {
                  "hostid": "10108",
              },
              "selectItems":"",
              "sortfield": "hostname",
              "sortorder": "DESC"
              },
              'auth': auth,
              'id': '1'
              }
    output = requestJson(url,values)
    return output


def  chaxun(groupid,items_value):

    host = hosts(auth, groupid) ##获取所有主机

    host_name = []
    host_id = []

    for i in host:
        host_id.append(i['hostid'])
        host_name.append(i['name'])
    hostall = dict(zip(host_id, host_name))  ## 所有主机     '10118': '云主机：10.8.8.65','10119': '云主机：10.8.8.66',


    host_names = []
    host_ids = []
    for i in host_id:    ##筛选，  有监控项目的   符合要求的主机ID，和主机名字
        host_id_value = items(auth, i) ## [{'itemid': '29272', 'key_': 'BiosDate'},{'itemid': '29272', 'key_': 'BiosDate'}]
        for index, value in enumerate(host_id_value):
            for k, v in value.items():
                if  items_value  in v:           ## items_value
                    host_ids.append(host_id_value[index]['itemid'])
                    host_names.append(i)

                    
                    

    host_names_list = []
    for i in   host_names:  ## 用符合要求的主机  获取它的名字
        for k, v in hostall.items():
            if i in k:
                host_names_list.append(v)


    history_value = []
    for i in host_ids:         ##查询主机ID的最新历史值
        history = his(auth, i)
        history_value.append(history[0]['lastvalue'])
    host_value = dict(zip(host_names_list, history_value))

    return  host_value  #返回主机和值的对应关系

ret = chaxun(5, "ProcThreadCount.[2]")#  组ID 和 想要查询的监控项目
print(ret)

创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都网站设计、成都网站制作、万全网络推广、成都小程序开发、万全网络营销、万全企业策划、万全品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们大的嘉奖；创新互联为所有大学生创业者提供万全建站搭建服务，24小时服务热线：13518219792，官方网址：www.cdcxhl.com

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

标题名称：利用zabbixapi带入组ID和监控项目键值获取所有主机的值-创新互联
链接分享：https://www.cdcxhl.com/article40/dejieo.html

成都网站建设公司_创新互联，为您提供服务器托管、外贸网站建设、微信小程序、网站设计公司、静态网站、小程序开发

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联