请选择 进入手机版 | 继续访问电脑版
点击联系客服
客服QQ:509006671 客服微信:mengfeiseo

广州老站长门户

 找回密码
 立即注册
查看: 87|回复: 50

分布式监视系统Zabbix-大量添加聚合图形

[复制链接]

1

主题

1

帖子

-7

积分

限制会员

积分
-7
发表于 2021-4-13 09:37:19 | 显示全部楼层 |阅读模式
以前部署了zabbix(3 . 4 . 4版)监视环境。主机很多,分支的主机组也很多,添加聚合图很麻烦,所以使用python脚本批量添加聚合图。脚本下载地址:https://pan.baidu.com/s/1bpApIPp(密码:wpts)脚本的工作方式如下:

[root@zabbix01~]#cd/opt/

[root@zabbix01opt]#ls

create  _ disk  _ space  _ usage  _ screen  . py  create  _ screen  . py

=====================================================。

[root  @ zabbix  01 opt]# cat  create  _ screen  . py

#!/bin/env  python

Importjson

Importurllib2

Importargparse

Importre

Re_digits=re.compile(r'(\d)')

defemb  _ numbers(s)3360

Pieces=re_digits.split(s)

Pieces[1336033602]=映射(int,Pieces[1336033602])

Returnpieces

defsort  _ strings  _ with  _ emb  _ numbers  2(列表):

Return  sorted  (alist,key=emb  _ numbers)

Defrequestjson  (URL,values) :

Data=json.dumps(values)

Req=urllib2.request  (URL,data,{ '内容类型' 3360 '应用程序/JSON-RPC'})

Res=urllib2.urlopen  (req,数据)

Output=json.loads(res.read())

Returnoutput

Def  authenticate  (URL、username、password)3360

Values={ ' jsonrpc  ' : ' 2.0 ',

Method':'user.login  ',

Params':{

“用户”:用户名,

Password':password

},

Id':'0 '

}

Output=请求JSON  (URL,values)

returnoutput[‘result’]

Defgethosts(组名、URL、auth) :

Host_list={}

Values={ ' jsonrpc  ' : ' 2.0 ',

Method':'hostgroup.get  ',

Params':{

Output':'extend  ',

Filter' : {'name' :组名称},

“选择主机”:[‘主机’]

},

Auth':auth,

Id':'2 '

}

Output=请求JSON  (URL,values)

forhostinoutput[' result  '][0][' hosts  ']3360

host  _ list[host[' host  ']]=(host[' host  id  '])

#returnhost_list

Hosts_sort=[]

forhostinsort  _ strings  _ with  _ emb  _ numbers  2(host  _ list  . keys())3360

hosts  _ sort  . append(host  _ list[host])

Returnhosts_sort

Defgetgraphs  (host  _ list,name  _ list,URL,auth,columns,graphtype=0,dynamic=0)336660

If(图形类型==0)3360

Selecttype=['graphid']

Select='selectGraphs  '

If(图形类型==1)3360

Select  type=['itemid  ',' value  _ type']

Select='selectItems  '

Graphs=[]

Forhostinhost  _ list:

Values=
({'jsonrpc': '2.0',
                   'method': 'graph.get',
                   'params': {
                       select: [selecttype, 'name'],
                       'output': ['graphid', 'name'],
                       'hostids': host,
                       'filter': {'name': name_list},
                       'sortfield': 'name'
                   },
                   'auth': auth,
                   'id': '3'
                   })
        output = requestjson(url, values)
        bb = sorted(output['result'])
        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': '600',
            'height': '100',
            'x': str(x),
            'y': str(y),
            'colspan': '1',
            'rowspan': '1',
        })
        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 = 'http://10.0.8.40/api_jsonrpc.php'
    username = 'Admin'
    password = 'qwkg@monitor'
    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()
======================================================================================
[root@zabbix01 opt]# cat create_Disk_space_usage_screen.py
#!/bin/env python
import json
import urllib2
import argparse
import re

re_digits = re.compile(r'(\d+)')

def emb_numbers(s):
    pieces=re_digits.split(s)
    pieces[1::2]=map(int,pieces[1::2])
    return pieces

def sort_strings_with_emb_numbers2(alist):
    return sorted(alist, key=emb_numbers)

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': ['host']
              },
              'auth': auth,
              'id': '2'
    }
    output = requestjson(url, values)
    for host in output['result'][0]['hosts']:
        host_list[host['host']]=(host['hostid'])

    #return host_list
    hosts_sort = []
    for host in sort_strings_with_emb_numbers2(host_list.keys()):
        hosts_sort.append(host_list[host])
    return  hosts_sort

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'

    graphs = []
    for host in host_list:
        values = ({'jsonrpc': '2.0',
                   'method': 'graph.get',
                   'params': {
                       select: [selecttype, 'name'],
                       'output': ['graphid', 'name'],
                       'hostids': host,
                       'filter': {'name': name_list},
                       'sortfield': 'name'
                   },
                   'auth': auth,
                   'id': '3'
                   })
        output = requestjson(url, values)
        bb = sorted(output['result'])
        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': '400',
            'height': '400',
            'x': str(x),
            'y': str(y),
            'colspan': '1',
            'rowspan': '1',
        })
        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 = 'http://10.0.8.40/api_jsonrpc.php'
    username = 'Admin'
    password = 'qwkg@monitor'
    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()
======================================================================================
上面两个脚本create_screen.py和create_Disk_space_usage_screen.py,脚本中只需要按照自己的实际zabbix访问情况修改三处:
url
username
password
前者用于批量生成负载、带宽、IO等监控的聚合图形,后者用于生成磁盘监控的聚合图形。
两个脚本唯一不同的就是width和height的值不一样。
批量生成聚合图形的操作如下:
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'Network traffic on bond0' -c 2 -n '财务系统---Network traffic on bond0'
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'CPU load' -c 2 -n '财务系统---CPU load'
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'CPU utilization' -c 2 -n '财务系统---CPU utilization'
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'Memory usage' -c 2 -n '财务系统---Memory usage'
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'Read and Write speed on /' -c 2 -n '财务系统---Read and Write speed on /'
[root@zabbix01 opt]# python create_screen.py  -g '财务系统'  -G 'Read and Write speed on /data' -c 2 -n '财务系统---Read and Write speed on /data'
[root@zabbix01 opt]# python create_Disk_space_usage_screen.py  -g '财务系统'  -G 'Disk space usage /' -c 3 -n '财务系统---Disk space usage /'
[root@zabbix01 opt]# python create_Disk_space_usage_screen.py  -g '财务系统'  -G 'Disk space usage /data' -c 3 -n '财务系统---Disk space usage /data'
对于以上命令中的参数解释:
-g    要显示zabbix的群组(注意这个是在zabbix界面的"图形"里显示的"群组"选项,不能随便写,必须是存在zabbix里的)。
-G    要显示的zabbix图形(注意这个是在zabbix界面的"图形"里显示的"图形"选项,不能随便写,必须是存在zabbix里的)。
-c    显示几列,注意要调整脚本里的:'width': ,'height':  参数来设置大小。
-n    在screen 里面显示的名称。
上面的命令的意思就是:把"财务系统"组里面每个服务器的bond0网卡、load负载、磁盘等监控图形,接每列4个图形(磁盘的按美3个图形)的显示在聚合图形里。
同理:如果添加其他主机组,即将上面的"财务系统" 统一替换掉即可!



如果后续zabbix监控的主机群组里又追加了新机器,那么就把之前生产的该群组的聚合图形删除,然后再按照上面的脚本命令再次重新生成聚合图形,这样新加入到主机群组内机器的聚合图形就会显示出来了。
回复

使用道具 举报

0

主题

791

帖子

-304

积分

限制会员

积分
-304
发表于 2021-4-13 09:40:16 | 显示全部楼层
没看完~~~~~~ 先顶,好同志
回复

使用道具 举报

0

主题

812

帖子

-255

积分

限制会员

积分
-255
发表于 2021-4-13 10:01:58 | 显示全部楼层
我是来刷分的,嘿嘿
回复

使用道具 举报

1

主题

776

帖子

-263

积分

限制会员

积分
-263
发表于 2021-4-13 10:23:09 | 显示全部楼层
不错不错,楼主您辛苦了。。。
回复

使用道具 举报

0

主题

817

帖子

-279

积分

限制会员

积分
-279
发表于 2021-4-13 10:44:55 | 显示全部楼层
没看完~~~~~~ 先顶,好同志
回复

使用道具 举报

0

主题

786

帖子

-301

积分

限制会员

积分
-301
发表于 2021-4-13 11:06:04 | 显示全部楼层
真是 收益 匪浅
回复

使用道具 举报

0

主题

775

帖子

-290

积分

限制会员

积分
-290
发表于 2021-4-13 11:26:45 | 显示全部楼层
真是 收益 匪浅
回复

使用道具 举报

1

主题

836

帖子

-323

积分

限制会员

积分
-323
发表于 2021-4-13 11:48:33 | 显示全部楼层
好帖,来顶下
回复

使用道具 举报

1

主题

786

帖子

-210

积分

限制会员

积分
-210
发表于 2021-4-13 12:08:58 | 显示全部楼层
学习了,谢谢分享、、、
回复

使用道具 举报

3

主题

823

帖子

-284

积分

限制会员

积分
-284
发表于 2021-4-13 12:33:48 | 显示全部楼层
支持一下
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|无图版|手机版|小黑屋|广州@IT精英团

GMT+8, 2021-5-8 12:28 , Processed in 0.124254 second(s), 25 queries .

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表