即一个模板下link大量的模块真人手机网页版,api来实现监控的添加

2019-11-07 作者:联系我们   |   浏览(191)

因为最近线上的Hadoop集群从mrv1升级到mrv2了,监控模板也跟着变动了。。

zabbix之所以能成为比较优秀的监控工具,个人觉得是因为两个特点:一个是数据的存放方式,方便做数据处理,容量规划,归档等,这个之前说过。另一个是其强大的api,利用其api可以方便的和其他的组件进行整合,比如cmdb可以通过zabbix api来实现监控的添加,更新和禁用等,zabbix的官方文档提供了比较详细的api列表。

zabbix的screen功能可以把graph聚合起来,统一进行展示,我们的需求是把同一个主机组的同一个item聚合起来,比如一个screen显示同一个组的所有主机的内存使用率,达到类似ganglia的效果,由于服务器较多,所以我们调用zabbix api来进行创建。

线上是200台左右的集群,模块采用了link的方式来添加,即一个模板下link大量的模块,然后主机添加到这个模板里。

因为最近添加screen的需求比较多,就简单写了一个python脚本用来自动化添加screen,有兴趣的可以借鉴下。

脚本如下:适用于v2.2.11

真人手机网页版 1

使用方式如下:

import json
import urllib2
import argparse
 
def requestjson(url, values):
    data = json.dumps(values)
    req = urllib2.Request(url, data, {'Content-Type': 'application/json-rpc'})
    res = urllib2.urlopen(req, data)
    output = json.loads(res.read())
 
    return output
 
def authenticate(url, username, password):
    values = {'jsonrpc': '2.0',
              'method': 'user.login',
              'params': {
                  'user': username,
                  'password': password
              },
              'id': '0'
    }
    output = requestjson(url, values)
 
    return output['result']
 
def gethosts(groupname, url, auth):
    host_list = []
    values = {'jsonrpc': '2.0',
              'method': 'hostgroup.get',
              'params': {
                  'output': 'extend',
                  'filter': {'name': groupname},
                  'selectHosts': ['hostid']
              },
              'auth': auth,
              'id': '2'
    }
    output = requestjson(url, values)
    for host in output['result'][0]['hosts']:
        host_list.append(host['hostid'])
 
    return host_list
 
def getgraphs(host_list, name_list, url, auth, columns, graphtype=0, dynamic=0):
    if (graphtype == 0):
        selecttype = ['graphid']
        select = 'selectGraphs'
    if (graphtype == 1):
        selecttype = ['itemid', 'value_type']
        select = 'selectItems'
 
    values = ({'jsonrpc': '2.0',
              'method': 'graph.get',
              'params': {
                  select: [selecttype, 'name'],
                  'output': ['graphid', 'name'],
                  'hostids': host_list,
                  'filter': {'name': name_list},
                  'sortfield': 'name'
              },
              'auth': auth,
              'id': '3'
              })
 
    output = requestjson(url, values)
    bb = sorted(output['result'])
 
    graphs = []
    if (graphtype == 0):
        for i in bb:
            graphs.append(i['graphid'])
    if (graphtype == 1):
        for i in bb:
            if int(i['value_type']) in (0, 3):
                graphs.append(i['itemid'])
 
    graph_list = []
    x = 0
    y = 0
    for graph in graphs:
        graph_list.append({
            'resourcetype': graphtype,
            'resourceid': graph,
            'width': '300',
            'height': '100',
            'x': str(x),
            'y': str(y),
            'colspan': '0',
            'rowspan': '0',
            'elements': '0',
            'valign': '0',
            'halign': '0',
            'style': '0',
            'url': '',
            'dynamic': str(dynamic)
        })
        x += 1
        if x == int(columns):
            x = 0
            y += 1
 
    return graph_list
 
def screencreate(url, auth, screen_name, graphids, columns):
    columns = int(columns)
    if len(graphids) % columns == 0:
        vsize = len(graphids) / columns
    else:
        vsize = (len(graphids) / columns) + 1
 
    values = {'jsonrpc': '2.0',
              'method': 'screen.create',
              'params': [{
                  'name': screen_name,
                  'hsize': columns,
                  'vsize': vsize,
                  'screenitems': []
              }],
              'auth': auth,
              'id': 2
              }
    for i in graphids:
        values['params'][0]['screenitems'].append(i)
    output = requestjson(url, values)
 
def main():
    url = ''
    username = 'admin'
    password = '__Q&(0sH1zNAdD'
    auth = authenticate(url, username, password)
    host_list = gethosts(groupname, url, auth)
    graph_ids = getgraphs(host_list, graphname, url, auth, columns)
    screencreate(url, auth, screen_name, graph_ids, columns)
 
if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('-g', dest='groupname', nargs='+', metavar='groupname', type=str, help='which group you want to select')
    parser.add_argument('-G', dest='graphname', nargs='+', metavar='graphname', type=str, help='which graph you want to select')
    parser.add_argument('-c', dest='columns', metavar='columns', type=int, help='the screen columns')
    parser.add_argument('-n', dest='screen_name', metavar='screen_name', type=str, help='the screen name')
    args = parser.parse_args()
 
    groupname = args.groupname
    graphname = args.graphname
    columns = args.columns
    screen_name = args.screen_name
 
    main()

编辑推荐:

python ./screen_host.py  -H 主机列表 -n screen名称 -G graph名称

使用方法:

安装部署分布式监控系统Zabbix 2.06 http://www.linuxidc.com/Linux/2013-07/86942.htm

具体的脚本:

python create_screen.py -g servers -G 'Network traffic on em1' -c 4 -n 'servers Network traffic on em1'

《安装部署分布式监控系统Zabbix 2.06》 http://www.linuxidc.com/Linux/2013-07/86942.htm

#!/usr/bin/env python
import urllib2
import sys
import json
import argparse
def requestJason(url,values):
    data = json.dumps(values)
    req = urllib2.Request(url, data, {'Content-Type': 'application/json-rpc'})
    response = urllib2.urlopen(req, data)
    data_get = response.read()
    output = json.loads(data_get)
    print output
    try:
        message = output['result']
    except:
        message = output['error']['data']
        quit()
    print json.dumps(message) 
    return output
           
def authenticate(url, username, password):
    values = {'jsonrpc': '2.0',
              'method': 'user.login',
              'params': {
                  'user': username,
                  'password': password
              },
              'id': '0'
              }
    idvalue = requestJason(url,values)
    return idvalue['result']
def getHosts(hostname,url,auth):
    host_list = []
    values = {'jsonrpc': '2.0',
              'method': 'host.get',
              'params': {
                  'output': ["hostid","host"],
                  'filter': {
                      'host': hostname
                  }
              },
              'auth': auth,
              'id': '2'
              }
    output = requestJason(url,values)
    for host in output['result']:
        host_list.append(host['hostid'])
    return host_list
def getGraphs(host_list,name_list, url, auth, columns, graphtype=0 ,dynamic=0):
    if (graphtype == 0):
        selecttype = ['graphid']
        select = 'selectGraphs'
    if (graphtype == 1):
        selecttype = ['itemid', 'value_type']
        select = 'selectItems'
    values = ({'jsonrpc': '2.0',
            "method": "graph.get",
            "params": {
                select: [selecttype,"name"],
                "output": ["graphid","name"],
                "hostids": host_list,                   
                "filter":{'name':name_list},
                "sortfield":"name",
            },
            "auth": auth,
            "id": '3'
        })
    print values
    output = requestJason(url,values)
    bb = sorted(output['result'],key = lambda x:x['hosts'][0]['hostid'])
    output['result'] = bb
    graphs = []
    if (graphtype == 0):
        for i in output['result']:
            print i
            graphs.append(i['graphid'])
    if (graphtype == 1):
        for i in output['result']:
            if int(i['value_type']) in (0, 3):
                graphs.append(i['itemid'])
    graph_list = []
    x = 0
    y = 0
    print graphs
    for graph in graphs:
        print "x is " + str(x)
        print "y is " + str(y)
        graph_list.append({
            "resourcetype": graphtype,
            "resourceid": graph,
            "width": "500",
            "height": "100",
            "x": str(x),
            "y": str(y),
            "colspan": "0",
            "rowspan": "0",
            "elements": "0",
            "valign": "0",
            "halign": "0",
            "style": "0",
            "url": "",
            "dynamic": str(dynamic)
        })
        x += 1
        print type(x)
        print type(columns)
        if x == int(columns):
            x = 0
            y += 1
    print graph_list
    return graph_list
def screenCreate(url, auth, screen_name, graphids, columns):
    columns = int(columns)
    if len(graphids) % columns == 0:
        vsize = len(graphids) / columns
    else:
        vsize = (len(graphids) / columns) + 1
    values = {"jsonrpc": "2.0",
              "method": "screen.create",
              "params": [{
                  "name": screen_name,
                  "hsize": columns,
                  "vsize": vsize,
                  "screenitems": []
              }],
              "auth": auth,
              "id": 2
              }
    for i in graphids:
        values['params'][0]['screenitems'].append(i)
    output = requestJason(url,values)
def main():
    url = ''
    username = 'xxxx'
    password = 'xxxx'
    auth = authenticate(url, username, password)
    host_list = getHosts(hostname,url,auth)
    print host_list
    graph_ids = getGraphs(host_list,graphname, url, auth, columns)
    screenCreate(url, auth, screenname, graph_ids, columns)
if __name__ == '__main__':
    parser = argparse.ArgumentParser(description='Create Zabbix screen from all of a host Items or Graphs.')
    parser.add_argument('-G', dest='graphname', nargs='+',metavar=('grah name'),
                        help='Zabbix Host Graph to create screen from')
    parser.add_argument('-H', dest='hostname', nargs='+',metavar=('10.19.111.145'),
                        help='Zabbix Host to create screen from')
    parser.add_argument('-n', dest='screenname', type=str,
                        help='Screen name in Zabbix.  Put quotes around it if you want spaces in the name.')
    parser.add_argument('-c', dest='columns', type=int,
                        help='number of columns in the screen')
    args = parser.parse_args()
    print args
    hostname = args.hostname
    screenname = args.screenname
    columns = args.columns
    graphname = args.graphname
    if columns is None:
        columns = len(graphname)
    print columns
    main()

不支持3.x版本的解决方法见 http://www.linuxidc.com/Linux/2017-03/141926.htm

CentOS 6.3下Zabbix安装部署 http://www.linuxidc.com/Linux/2013-05/83786.htm

一些Zabbix相关教程集合

一些Zabbix相关教程集合

Zabbix分布式监控系统实践 http://www.linuxidc.com/Linux/2013-06/85758.htm

Ubuntu 14.04下Zabbix2.4.5 源码编译安装  http://www.linuxidc.com/Linux/2015-05/117657.htm

Ubuntu 14.04下Zabbix2.4.5 源码编译安装  http://www.linuxidc.com/Linux/2015-05/117657.htm

CentOS 6.3下Zabbix监控apache server-status http://www.linuxidc.com/Linux/2013-05/84740.htm

CentOS 7 LNMP环境搭建Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140134.htm

CentOS 7 LNMP环境搭建Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140134.htm

CentOS 6.3下Zabbix监控MySQL数据库参数 http://www.linuxidc.com/Linux/2013-05/84800.htm

Ubuntu 16.04安装部署监控系统Zabbix2.4  http://www.linuxidc.com/Linux/2017-03/141436.htm

Ubuntu 16.04安装部署监控系统Zabbix2.4  http://www.linuxidc.com/Linux/2017-03/141436.htm

 

Zabbix监控安装部署及警报配置  http://www.linuxidc.com/Linux/2017-03/141611.htm

Zabbix监控安装部署及警报配置  http://www.linuxidc.com/Linux/2017-03/141611.htm

这样算下来一台机器差不多有 215个item.

Ubuntu 16.04下安装部署Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140395.htm

Ubuntu 16.04下安装部署Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140395.htm

为了增加NM的监控,也采用了link的方式来连接模板,在页面上link时发现一直返回一个空白页。

CentOS 6.3下Zabbix监控apache server-status http://www.linuxidc.com/Linux/2013-05/84740.htm

CentOS 6.3下Zabbix监控apache server-status http://www.linuxidc.com/Linux/2013-05/84740.htm

为了快速上线,改变了下方法,使用了host.update的api,直接把host link到NM的模板。

CentOS 7 下 Zabbix 3.0安装详解 http://www.linuxidc.com/Linux/2017-03/141716.htm

CentOS 7 下 Zabbix 3.0安装详解 http://www.linuxidc.com/Linux/2017-03/141716.htm

回过头来看这个问题:

64位CentOS 6.2下安装Zabbix 2.0.6   http://www.linuxidc.com/Linux/2014-11/109541.htm

64位CentOS 6.2下安装Zabbix 2.0.6   http://www.linuxidc.com/Linux/2014-11/109541.htm

在通过页面link模板时,其实也是调用了zabbix template相关的api(具体调用了template.update方法)

ZABBIX 的详细介绍:请点这里
ZABBIX 的下载地址:请点这里

ZABBIX 的详细介绍:请点这里
ZABBIX 的下载地址:请点这里

直接通过脚本来调用api测试:

本文永久更新链接地址:http://www.linuxidc.com/Linux/2017-03/141922.htm

本文永久更新链接地址:http://www.linuxidc.com/Linux/2017-03/141925.htm

测试脚本

真人手机网页版 2

真人手机网页版 3

#!/usr/bin/env python

import urllib2

import sys

import json

def requestJason(url,values):

    data = json.dumps(values)

    print data

    req = urllib2.Request(url, data, {'Content-Type': 'application/json-rpc'})

    response = urllib2.urlopen(req, data)

    data_get = response.read()

    output = json.loads(data_get)

    print output

    try:

        message = output['result']

    except:

        message = output['error']['data']

        quit()

    print json.dumps(message) 

    return output

def authenticate(url, username, password):

    values = {'jsonrpc': '2.0',

              'method': 'user.login',

              'params': {

                  'user': username,

本文由美高梅赌堵59599发布于联系我们,转载请注明出处:即一个模板下link大量的模块真人手机网页版,api来实现监控的添加

关键词: