Zabbix-采用python脚本进行批量添加聚合图形

作者: 小黑佬 | 来源:发表于2019-10-10 18:16 被阅读0次

Zabbix-采用python脚本进行批量添加聚合图形
按钮
python 脚本实现 luajit 批量加密
zabbix操作
python zabbix批量添加主机脚本
给家人批量下载音乐
华为交换机常见链路聚合操作整理第十三天
Ubuntu 批量添加用户/批量删除用户
Shell编程--case,for,while,until
Python脚本批量给文件添加内容

python2环境下测试正常，zabbix4.0版本测试正常

#create_screen.py,用于批量生成负载、带宽、IO等监控的聚合图形
#!/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': '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()

#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()

#例子：
批量生成聚合图形的操作如下：
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'Network traffic on eth1' -c 12 -n "所有--Network traffic on eth1" 
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'Network traffic on eth1' -c 3 -n "所有--Network traffic on eth1"  
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'Network traffic on eth0' -c 3 -n "所有--Network traffic on eth0" 
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'CPU load' -c 3 -n "所有--CPU load"                                      
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'CPU utilization' -c 3 -n "所有--CPU utilization" 
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'Memory usage' -c 3 -n "所有--Memory usage"                  
[root@yunwei shell]#  python create_screen.py  -g 'Linux servers' -G 'Read and Write speed on /' -c 3 -n "所有--Read and Write speed on /"
 
对于以上命令中的参数解释：
-g    要显示zabbix的群组（注意这个是在zabbix界面的"图形"里显示的"群组"选项，不能随便写，必须是存在zabbix里的）。
-G    要显示的zabbix图形（注意这个是在zabbix界面的"图形"里显示的"图形"选项，不能随便写，必须是存在zabbix里的）。
-c    显示几列，注意要调整脚本里的：'width': ，'height':  参数来设置大小。
-n    在screen 里面显示的名称。
 
上面的命令的意思就是：把"财务系统"组里面每个服务器的eth0网卡、load负载、磁盘等监控图形，接每列4个图形（磁盘的按美3个图形）的显示在聚合图形里。
 
同理：如果添加其他主机组，即将上面的"Linux servers" 统一替换掉即可！

image.png

Zabbix-采用python脚本进行批量添加聚合图形
python2环境下测试正常，zabbix4.0版本测试正常
按钮
学会了批量添加图形，呜呜！
python 脚本实现 luajit 批量加密
python 脚本实现 luajit 批量加密
zabbix操作
添加host 添加 Screens (聚合图形) 用户授权自动发现 Configuration --> Disc...
python zabbix批量添加主机脚本
转载:https://www.cnblogs.com/momoshouhu/p/8053907.html1.安装x...
给家人批量下载音乐
前提是您有一台可以上网的电脑如下使用windows电脑批量下载的方法：即采用python脚本，启动Xming界面，...
华为交换机常见链路聚合操作整理第十三天
1、将成员接口批量加入聚合组。在Eth-Trunk1中批量加入10个成员接口。脚本： system-view ...
Ubuntu 批量添加用户/批量删除用户
批量添加用户 1 . 准备文件 ws1_2015_add.sh 2 . 运行脚本批量添加用户 3 . 准备密码文本...
Shell编程--case,for,while,until
shell多分支case语句 for循环语法一：批量压缩文件脚本语法二：从1加到100 批量添加用户批量...
Python脚本批量给文件添加内容
# -*- coding: utf-8 -*- import os def add_text(path,filep...