zabbix自动添加删除主机的python脚本

简介:
+关注继续查看

    python写的zabbix自动添加和删除主机的脚本,原理是模拟登陆zabbix web页面中添加、删除主机的操作。如果你是添加或是删除多台主机的话可以写个脚本循环或是多线程来调用此脚本删除添加即可。


  1. #!/usr/bin/env python  
  2. # -*- coding: utf-8 -*-  
  3. #zabbix的自动发现功能有时由于网络等原因自动添加主机比较慢  
  4. #或者不能添加地址段内所有的主机,基于此,写此脚本根据单IP  
  5. #和单IP应用来添加删除主机。  
  6. #在zabbix2.0.3/4上测试通过  
  7.  
  8. import re,urllib,urllib2,cookielib  
  9. import MySQLdb  
  10.  
  11. zabbix_server = '192.168.1.2' 
  12.  
  13. class web_form:  
  14.     post_data=""#登陆提交的参数  
  15.     def __init__(self):  
  16.         '''''初始化类,并建立cookies值''' 
  17.         cj = cookielib.CookieJar()  
  18.         opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(cj))  
  19.         opener.addheaders = [('User-agent''Mozilla/5.0 (Windows NT 6.2; WOW64; rv:19.0) Gecko/20100101 Firefox/19.0')]  
  20.         urllib2.install_opener(opener)  
  21.  
  22.     def login(self,loginurl):  
  23.         '''''模拟登陆,获取认证的后的session''' 
  24.         req = urllib2.Request(loginurl,self.post_data)  
  25.         _response = urllib2.urlopen(req)  
  26.         for i in str(_response.info()).split('\n'):  
  27.             if 'Set-Cookie' in i:  
  28.                 sid = i.split("=")[1].split(";")[0][16:]  
  29.                 break 
  30.         _d=_response.read()  
  31.         return _d,sid  
  32.  
  33.     def getpagehtml(self,pageurl):  
  34.         '''''获取目标网站任意一个页面的html代码''' 
  35.         req2=urllib2.Request(pageurl,self.post_data)  
  36.         _response2=urllib2.urlopen(req2)  
  37.         status = _response2.code  
  38.         _d2=_response2.read()  
  39.         return _d2  
  40.  
  41. def center(sql):  
  42.     try:  
  43.         center_ip = zabbix_server  
  44.         center_user = 'root' 
  45.         center_passwd = '123456789' 
  46.         conn = MySQLdb.connect(host = center_ip,user = center_user,passwd = center_passwd,connect_timeout=10)  
  47.         cursor = conn.cursor()   
  48.         cursor.execute(sql)  
  49.         alldata = cursor.fetchall()  
  50.         cursor.close()  
  51.         conn.close()  
  52.         return alldata  
  53.     except Exception,e:  
  54.         return '0' 
  55.  
  56. def operation(action,hostip,post_dirc):  
  57.     boss = web_form()  
  58.     #参递一个post参数  
  59.     url = "http://%s/zabbix" % zabbix_server  
  60.     boss.post_data = urllib.urlencode({"autologin":"1","enter":"Sign in","name":"admin","password":"zabbix"})  
  61.     login,sid = boss.login("%s/index.php" % url)#首先登陆zabbix,获取认证的sid  
  62.     if action == 'add':#添加主机  
  63.         sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip  
  64.         hostid = center(sql)  
  65.         if len(hostid) != 0:  
  66.             print "Server %s is already in zabbix status !" % hostip  
  67.         else:  
  68.             post_form = {'form':'创建主机','form_refresh':'2','host':hostip,'interfaces[1][dns]':'','interfaces[1][interfaceid]':'1','interfaces[1][ip]':hostip,'interfaces[1][isNew]':'true','interfaces[1][port]':'10050','interfaces[1][type]':'1','interfaces[1][useip]':'1','inventory_mode':'-1','ipmi_authtype':'-1','ipmi_password':'','ipmi_privilege':'2','ipmi_username':'','macros[0][macro]':'','macros[0][value]':'','mainInterfaces[1]':'1','newgroup':'','proxy_hostid':'0','save':'存档','sid':sid,'status':'0','visiblename':hostip}  
  69.             post_form = dict(post_form,**post_dirc)  
  70.             boss.post_data=urllib.urlencode(post_form)  
  71.             add_host = boss.getpagehtml("%s/hosts.php" % url)  
  72.             sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip  
  73.             hostid = center(sql)  
  74.             if len(hostid) != 0:  
  75.                 print "Add %s in zabbix success !" % hostip  
  76.             else:  
  77.                 print "Add %s in zabbix failure !" % hostip  
  78.     elif action == 'del':#删除主机  
  79.         sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip  
  80.         hostid = center(sql)#从zabbix服务器端数据库取出要删除ip的hostid号  
  81.         if len(hostid) != 0:  
  82.             hostid = hostid[0][0]  
  83.             a = 'hosts[%s]' % hostid  
  84.             boss.post_data=urllib.urlencode({'form_refresh':'1','go':'delete','goButton':'确认 (1)',a:hostid,'sid':sid})  
  85.             del_host = boss.getpagehtml("%s/hosts.php" % url)  
  86.             hostid = center(sql)  
  87.             sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip  
  88.             if len(hostid) != 0:  
  89.                 print "Delete %s from zabbix failure !" % hostip  
  90.             else:  
  91.                 print "Delete %s from zabbix success !" % hostip  
  92.         else:  
  93.             print "Server %s not in zabbix status !" % hostip  
  94.  
  95. def main(block,action,hostip):#根据IP的应用,确定需要添加到zabbix中的组和需要应用的模板  
  96.     if block == "adb" or block == "ldb" or block == "ccs":  
  97.         sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('WD_ADB_LDB','Linux servers')" 
  98.         groupdata = center(sql)  
  99.         sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','MySQL_status','Linux_disk_io')" 
  100.         templates = center(sql)  
  101.     elif "_s" in block:  
  102.         sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('Linux servers','WD_SLAVE')" 
  103.         groupdata = center(sql)  
  104.         sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','MySQL_status','Slave_Status','Linux_disk_io')" 
  105.         templates = center(sql)  
  106.     else:  
  107.         sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('Linux servers','WD_GS')" 
  108.         groupdata = center(sql)  
  109.         sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','Linux_disk_io')" 
  110.         templates = center(sql)  
  111.     templatesdirc = {}  
  112.     groupdirc = {}  
  113.     for i in groupdata:  
  114.         groups = 'groups[%s]' % str(i[0])  
  115.         groupdirc[groups] = str(i[0])  
  116.     for i in templates:  
  117.         groups = 'templates[%s]' % str(i[0])  
  118.         templatesdirc[groups] = str(i[1])  
  119.     post_dirc = dict(groupdirc,**templatesdirc)  
  120.     operation(action,hostip,post_dirc)  
  121.  
  122. if __name__=="__main__":  
  123.     block = 'adb_s' 
  124.     hostip = '6.6.6.6' 
  125.     action = 'add' 
  126.     action = 'del' 
  127.     main(block,action,hostip) 

 



本文转自 lover00751CTO博客,原文链接:http://blog.51cto.com/wangwei007/1139982,如需转载请自行联系原作者

相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
9月前
|
Python
使用Python自动发送邮件
使用Python自动发送邮件
169 0
使用Python自动发送邮件
|
9月前
|
XML JSON 自然语言处理
python接口自动化(三十三)-python自动发邮件总结及实例说明番外篇——下(详解)
发邮件前我们需要了解的是邮件是怎么一个形式去发送到对方手上的,通俗点来说就是你写好一封信,然后装进信封,写上地址,贴上邮票,然后就近找个邮局,把信仍进去,其他的就不关心了,只是关心时间,而电子邮件不像日常发送邮件的按天算,时间都是按秒算的。
126 0
python接口自动化(三十三)-python自动发邮件总结及实例说明番外篇——下(详解)
|
9月前
|
数据挖掘 Python
用Python学线性代数:自动拟合数据分布
用Python学线性代数:自动拟合数据分布
用Python学线性代数:自动拟合数据分布
|
9月前
|
存储 Python
【Pyqt实战】1-100算式练习题自动生成器(含UI界面,python代码),可自行选择参数
【Pyqt实战】1-100算式练习题自动生成器(含UI界面,python代码),可自行选择参数
【Pyqt实战】1-100算式练习题自动生成器(含UI界面,python代码),可自行选择参数
|
10月前
|
Python
python实操案例__01—根据文本数据自动绘制轨迹
用python根据文本数据自动绘制轨迹
|
10月前
|
数据安全/隐私保护 Python
|
10月前
|
Python
python做的快手自动评论工具 源码开源
可以自动打开快手 评论
71 0
|
10月前
|
自然语言处理 运维 调度
自动化运维?看看Python怎样完成自动任务调度⛵
本文讲解如何使用Python的schedule库完成自动化调度程序,通过代『发送邮件』这一代码实例展示了构建任务与任务调度的全过程。
2627 4
自动化运维?看看Python怎样完成自动任务调度⛵
|
10月前
|
Web App开发 测试技术
Selenium+python之隐藏浏览器的“Chrome正在受到自动软件的控制“提示语
Selenium+python之隐藏浏览器的“Chrome正在受到自动软件的控制“提示语
250 0
相关产品
云迁移中心
推荐文章
更多
推荐镜像
更多