备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

zabbix python add host py

2018-12-21 1033
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 没有该主机组的时候要先添加主机组：./python_zabbix_host.py -A yournamevi python_zabbix_host.py!/usr/bin/pythoncoding:utf-8import jsonimport...

没有该主机组的时候要先添加主机组：./python_zabbix_host.py -A yourname

vi python_zabbix_host.py

!/usr/bin/python

coding:utf-8

import json
import urllib2
from urllib2 import URLError
import sys, argparse
import xlrd
import socket
import os

os.chdir('/usr/local/src')
os.system('yum install -y unzip')
if os.path.exists('setuptools-38.2.4') == False:
os.system(
'wget https://pypi.python.org/packages/69/56/f0f52281b5175e3d9ca8623dadbc3b684e66350ea9e0006736194b265e99/setuptools-38.2.4.zip#md5=e8e05d4f8162c9341e1089c80f742f64 --no-check-certificate')
os.system('unzip setuptools-38.2.4.zip')
os.chdir('/usr/local/src/setuptools-38.2.4')
os.system('python setup.py build')
os.system('python setup.py install')
os.chdir('/usr/local/src')
if os.path.exists('pip-9.0.1') == False:
os.system(
'wget --no-check-certificate https://pypi.python.org/packages/11/b6/abcb525026a4be042b486df43905d6893fb04f05aac21c32c638e939e447/pip-9.0.1.tar.gz#md5=35f01da33009719497f01a4ba69d63c9')
os.system('tar -xzvf pip-9.0.1.tar.gz')
os.chdir('/usr/local/src/pip-9.0.1')
os.system('python setup.py build')
os.system('python setup.py install')
os.system('pip install xlrd')
else:
os.chdir('/usr/local/src/pip-9.0.1')
os.system('pip install xlrd')

defaultencoding = 'utf-8'
if sys.getdefaultencoding() != defaultencoding:
reload(sys)
sys.setdefaultencoding(defaultencoding)

def get_host_ip():
"""
查询本机ip地址
:return: ip
"""
try:
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect(('8.8.8.8', 80))
ip = s.getsockname()[0]
finally:
s.close()

return ip

a = get_host_ip()

class zabbix_api:
def init(self):
self.url = 'http://' + a + '/zabbix/api_jsonrpc.php' # 修改URL
self.header = {"Content-Type": "application/json"}

def user_login(self):
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "user.login",
        "params": {
            "user": "admin",  # web页面登录用户名
            "password": "zabbix"  # web页面登录密码
        },
        "id": 0
    })

    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "\033[041m 用户认证失败，请检查 !\033[0m", e.code
    else:
        response = json.loads(result.read())
        result.close()
        # print response['result']
        self.authID = response['result']
        return self.authID

def host_get(self, hostName=''):
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "host.get",
        "params": {
            "output": "extend",
            "filter": {"host": hostName}
        },
        "auth": self.user_login(),
        "id": 1
    })
    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        if hasattr(e, 'reason'):
            print 'We failed to reach a server.'
            print 'Reason: ', e.reason
        elif hasattr(e, 'code'):
            print 'The server could not fulfill the request.'
            print 'Error code: ', e.code
    else:
        response = json.loads(result.read())
        # print response
        result.close()
        print "主机数量: \033[31m%s\033[0m" % (len(response['result']))
        for host in response['result']:
            status = {"0": "OK", "1": "Disabled"}
            available = {"0": "Unknown", "1": "available", "2": "Unavailable"}
            # print host
            if len(hostName) == 0:
                print "HostID : %s\t HostName : %s\t Status :\033[32m%s\033[0m \t Available :\033[31m%s\033[0m" % (
                host['hostid'], host['name'], status[host['status']], available[host['available']])
            else:
                print "HostID : %s\t HostName : %s\t Status :\033[32m%s\033[0m \t Available :\033[31m%s\033[0m" % (
                host['hostid'], host['name'], status[host['status']], available[host['available']])
                return host['hostid']

def hostgroup_get(self, hostgroupName=''):
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "hostgroup.get",
        "params": {
            "output": "extend",
            "filter": {
                "name": hostgroupName
            }
        },
        "auth": self.user_login(),
        "id": 1,
    })

    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        # print result.read()
        response = json.loads(result.read())
        result.close()
        # print response()
        for group in response['result']:
            if len(hostgroupName) == 0:
                print "hostgroup:  \033[31m%s\033[0m \tgroupid : %s" % (group['name'], group['groupid'])
            else:
                print "hostgroup:  \033[31m%s\033[0m\tgroupid : %s" % (group['name'], group['groupid'])
                self.hostgroupID = group['groupid']
                return group['groupid']

def template_get(self, templateName=''):
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "template.get",
        "params": {
            "output": "extend",
            "filter": {
                "name": templateName
            }
        },
        "auth": self.user_login(),
        "id": 1,
    })

    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        response = json.loads(result.read())
        result.close()
        # print response
        for template in response['result']:
            if len(templateName) == 0:
                print "template : \033[31m%s\033[0m\t  id : %s" % (template['name'], template['templateid'])
            else:
                self.templateID = response['result'][0]['templateid']
                print "Template Name :  \033[31m%s\033[0m " % templateName
                return response['result'][0]['templateid']

def hostgroup_create(self, hostgroupName):

    if self.hostgroup_get(hostgroupName):
        print "hostgroup  \033[42m%s\033[0m is exist !" % hostgroupName
        sys.exit(1)
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "hostgroup.create",
        "params": {
            "name": hostgroupName
        },
        "auth": self.user_login(),
        "id": 1
    })
    request = urllib2.Request(self.url, data)

    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        response = json.loads(result.read())
        result.close()
        print "\033[042m 添加主机组:%s\033[0m  hostgroupID : %s" % (hostgroupName, response['result']['groupids'])

def host_create_andy(self, hostName, visibleName, hostip, hostgroupName, templateName):
    if self.host_get(hostip):
        print "\033[041m该主机已经添加!\033[0m"
        sys.exit(1)

    group_list = []
    template_list = []
    for i in hostgroupName.split(','):
        var = {}
        var['groupid'] = self.hostgroup_get(i)
        group_list.append(var)
    for i in templateName.split(','):
        var = {}
        var['templateid'] = self.template_get(i)
        template_list.append(var)

    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "host.create",
        "params": {
            "host": hostName,
            "name": visibleName,
            "interfaces": [
                {
                    "type": 1,  # 1：表示IP；2表示SNMP
                    "main": 1,
                    "useip": 1,
                    "ip": hostip,
                    "dns": "",
                    "port": "10050"  # IP端口10050；SNMP端口161
                }
            ],
            "groups": group_list,
            "templates": template_list,
        },
        "auth": self.user_login(),
        "id": 1
    })
    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        response = json.loads(result.read())
        print "添加主机 : \033[42m%s\031[0m \tid :\033[31m%s\033[0m" % (hostip, response['result']['hostids'])
        result.close()

def host_create(self, hostip, hostgroupName, templateName):
    if self.host_get(hostip):
        print "\033[041m该主机已经添加!\033[0m"
        sys.exit(1)

    group_list = []
    template_list = []
    for i in hostgroupName.split(','):
        var = {}
        var['groupid'] = self.hostgroup_get(i)
        group_list.append(var)
    for i in templateName.split(','):
        var = {}
        var['templateid'] = self.template_get(i)
        template_list.append(var)

    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "host.create",
        "params": {
            "host": hostip,
            "interfaces": [
                {
                    "type": 2,
                    "main": 1,
                    "useip": 1,
                    "ip": hostip,
                    "dns": "",
                    "port": "161"
                }
            ],
            "groups": group_list,
            "templates": template_list,
        },
        "auth": self.user_login(),
        "id": 1
    })
    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        response = json.loads(result.read())
        result.close()
        print "添加主机 : \033[42m%s\031[0m \tid :\033[31m%s\033[0m" % (hostip, response['result']['hostids'])

def host_disable(self, hostip):
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "host.update",
        "params": {
            "hostid": self.host_get(hostip),
            "status": 1
        },
        "auth": self.user_login(),
        "id": 1
    })
    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])
    try:
        result = urllib2.urlopen(request)
    except URLError as e:
        print "Error as ", e
    else:
        response = json.loads(result.read())
        result.close()
        print '----主机现在状态------------'
        print self.host_get(hostip)

def host_delete(self, hostid):
    hostid_list = []
    # print type(hostid)
    for i in hostid.split(','):
        var = {}
        var['hostid'] = self.host_get(i)
        hostid_list.append(var)
    data = json.dumps({
        "jsonrpc": "2.0",
        "method": "host.delete",
        "params": hostid_list,
        "auth": self.user_login(),
        "id": 1
    })

    request = urllib2.Request(self.url, data)
    for key in self.header:
        request.add_header(key, self.header[key])

    try:
        result = urllib2.urlopen(request)
    except Exception, e:
        print  e
    else:

        result.close()
        print "主机 \033[041m %s\033[0m  已经删除 !" % hostid

if name == "main":
zabbix = zabbix_api()
parser = argparse.ArgumentParser(description='zabbix api ', usage='%(prog)s [options]')
parser.add_argument('-H', '--host', nargs='?', dest='listhost', default='host', help='查询主机')
parser.add_argument('-G', '--group', nargs='?', dest='listgroup', default='group', help='查询主机组')
parser.add_argument('-T', '--template', nargs='?', dest='listtemp', default='template', help='查询模板信息')
parser.add_argument('-A', '--add-group', nargs=1, dest='addgroup', help='添加主机组')
parser.add_argument('-C', '--add-host', dest='addhost', nargs=3,
metavar=('192.168.2.1', 'test01,test02', 'Template01,Template02'), help='添加主机,多个主机组或模板使用分号')
parser.add_argument('-d', '--disable', dest='disablehost', nargs=1, metavar=('192.168.2.1'), help='禁用主机')
parser.add_argument('-L', '--allin', dest='allin', nargs='?', default='allin', help='从Excel批量导入主机')
parser.add_argument('-D', '--delete', dest='deletehost', nargs='+', metavar=('192.168.2.1'), help='删除主机,多个主机之间用分号')
parser.add_argument('-v', '--version', action='version', version='%(prog)s 1.0')
if len(sys.argv) == 1:
print parser.print_help()
else:
args = parser.parse_args()

    if args.listhost != 'host':
        if args.listhost:
            zabbix.host_get(args.listhost)
        else:
            zabbix.host_get()
    if args.listgroup != 'group':
        if args.listgroup:
            zabbix.hostgroup_get(args.listgroup)
        else:
            zabbix.hostgroup_get()
    if args.listtemp != 'template':
        if args.listtemp:
            zabbix.template_get(args.listtemp)
        else:
            zabbix.template_get()
    if args.addgroup:
        zabbix.hostgroup_create(args.addgroup[0])
    if args.addhost:
        zabbix.host_create(args.addhost[0], args.addhost[1], args.addhost[2])
    if args.disablehost:
        zabbix.host_disable(args.disablehost)
    if args.deletehost:
        zabbix.host_delete(args.deletehost[0])
    if args.allin != 'allin':
        workbook = xlrd.open_workbook('zabbix_host_add.xlsx')  # Excel名，表格列 主机名、显示名、IP、主机组、模板
        for row in xrange(workbook.sheets()[0].nrows):
            hostname = workbook.sheets()[0].cell(row, 0).value
            visible = workbook.sheets()[0].cell(row, 1).value
            hostip = workbook.sheets()[0].cell(row, 2).value
            hostgroup = workbook.sheets()[0].cell(row, 3).value
            hosttemp = workbook.sheets()[0].cell(row, 4).value

            zabbix.host_create_andy(hostname, visible, hostip, hostgroup, hosttemp)
文章标签：
Python
监控
关键词：
Python py
Zabbix python
Python zabbix
Zabbix host
Python add
sktj
目录
相关文章
漏刻有时
|
9月前
|
JSON 监控 前端开发
python对接API二次开发高级实战案例解析：Zabbix API封装类实现获取认证密钥、所有主机组、所有主机、所有监控项和历史数据
python对接API二次开发高级实战案例解析：Zabbix API封装类实现获取认证密钥、所有主机组、所有主机、所有监控项和历史数据
漏刻有时
295 0
桃李春风一杯酒
|
3月前
|
Python
Python 的其他主题：Python 中的 `__init__.py` 文件有什么作用？
Python 的其他主题：Python 中的 `__init__.py` 文件有什么作用？
桃李春风一杯酒
35 1
小小杨树1
|
2月前
|
C++ 计算机视觉 Python
【Py调用C++】使用使用python调用C++生成dll处理图像（OPENCV）
【Py调用C++】使用使用python调用C++生成dll处理图像（OPENCV）
小小杨树1
38 0
【Py调用C++】使用使用python调用C++生成dll处理图像（OPENCV）
opensca社区
|
4月前
|
供应链 安全 开发工具
供应链安全情报 | 恶意py包伪装代理SDK进行后门攻击，目标锁定python开发者
2023年11月28号，悬镜供应链安全实验室在Pypi官方仓库（https://pypi.org）监测到两起伪装成http和socks5代理SDK的开源组件投毒事件。python开发者一旦下载安装这些投毒Py包（libproxy、libsocks5），会触发执行Py包中的恶意代码，最终将导致开发者系统被投毒者植入恶意后门。
opensca社区
45 0
听风de歌
|
7月前
|
监控 安全 Ubuntu
用python部署zabbix
用python部署zabbix
听风de歌
60 1
Python知识大全
|
8月前
|
Python
Python: __init__.py 作用
Python: __init__.py 作用
Python知识大全
39 0
Crossin的编程教室
|
9月前
|
Python
#PY小贴士# 别弄错了 Python 里的这几个运算符
会出现这样问题的同学，多半是之前用过其他的编程语言，所以习惯性地认为 ^ 是表示次方，& 是表示逻辑与（同时满足条件）、| 是表示逻辑或（满足条件之一）。
Crossin的编程教室
46 0
游客oh6lc6rmikcss
|
11月前
|
安全 Linux 数据安全/隐私保护
基于Python的PY#RATIONRAT偷偷收集敏感信息
基于Python的PY#RATIONRAT偷偷收集敏感信息
游客oh6lc6rmikcss
78 0
亚索不会吹风
|
11月前
|
Python
python pyinstaller “单个” py文件打包
python pyinstaller “单个” py文件打包
亚索不会吹风
102 0
刘金玉编程
|
11月前
|
Python
python中利用py帮助命令扩展开发知识面
python中利用py帮助命令扩展开发知识面
刘金玉编程
57 0

热门文章

最新文章

  • 1
    阿里云 MaxCompute MaxFrame 开启免费邀测，统一 Python 开发生态
  • 2
    使用Python实现DBSCAN聚类算法
  • 3
    在Python Web开发过程中：数据库与缓存，MySQL和NoSQL数据库的主要差异是什么？
  • 4
    流畅的 Python 第二版（GPT 重译）（一）(1)
  • 5
    【Python】python天气数据抓取与数据分析（源码+论文）【独一无二】
  • 6
    Python 学习之路 01基础入门---【Python安装，Python程序基本组成】
  • 7
    流畅的 Python 第二版（GPT 重译）（十一）(1)
  • 8
    Python 数据分析（PYDA）第三版（三）（1）
  • 9
    Python函数使用(四)
  • 10
    Python速成篇（基础语法）上
  • 1
    Python用机器学习算法进行因果推断与增量、增益模型Uplift Modeling智能营销模型
    28
  • 2
    Python用RNN神经网络：LSTM、GRU、回归和ARIMA对COVID19新冠疫情人数时间序列预测
    42
  • 3
    PYTHON用时变马尔可夫区制转换（MARKOV REGIME SWITCHING）自回归模型分析经济时间序列
    13
  • 4
    数据分享|Python决策树、随机森林、朴素贝叶斯、KNN（K-最近邻居）分类分析银行拉新活动挖掘潜在贷款客户
    20
  • 5
    Python监控主机是否存活,并发报警邮件
    5
  • 6
    【Python实用技能】建议收藏：自动化实现网页内容转PDF并保存的方法探索（含代码，亲测可用）
    20
  • 7
    Python 妙用运算符重载——玩出“点”花样来（上）
    25
  • 8
    python 教你如何创建一个自定义库 colorlib.py
    17
  • 9
    Python 一步一步教你用pyglet制作汉诺塔游戏
    14
  • 10
    Python变量类型
    8

    • 相关课程

    更多
  • Python爬虫实战
  • Python开发基础入门
  • Python常用数据科学库
  • Python网络爬虫实战
  • Python完全自学手册图文教程
  • Python基础快速入门实战教程

    • 相关电子书

    更多
  • From Python Scikit-Learn to Sc
  • Data Pre-Processing in Python:
  • 双剑合璧-Python和大数据计算平台的结合

    • 相关实验场景

    更多
  • 用Python画圣诞树
  • 使用Python完成RDS数据开发及分析
  • Python选择及循环结构
  • 云端Python及基本操作
  • Python网络通信程序典型应用
  • Python新手入门（Anolis OS）

    • 推荐镜像

    更多
  • zabbix
  • mariadb
  • exim
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）