zabbix自动添加删除主机的python脚本
2013-02-25 16:51
453 查看
python写的zabbix自动添加和删除主机的脚本,原理是模拟登陆zabbix web页面中添加、删除主机的操作。如果你是添加或是删除多台主机的话可以写个脚本循环或是多线程来调用此脚本删除添加即可。
本文出自 “王伟” 博客,请务必保留此出处http://wangwei007.blog.51cto.com/68019/1139982
#!/usr/bin/env python # -*- coding: utf-8 -*- #zabbix的自动发现功能有时由于网络等原因自动添加主机比较慢 #或者不能添加地址段内所有的主机,基于此,写此脚本根据单IP #和单IP应用来添加删除主机。 #在zabbix2.0.3/4上测试通过 import re,urllib,urllib2,cookielib import MySQLdb zabbix_server = '192.168.1.2' class web_form: post_data=""#登陆提交的参数 def __init__(self): '''''初始化类,并建立cookies值''' cj = cookielib.CookieJar() opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(cj)) opener.addheaders = [('User-agent', 'Mozilla/5.0 (Windows NT 6.2; WOW64; rv:19.0) Gecko/20100101 Firefox/19.0')] urllib2.install_opener(opener) def login(self,loginurl): '''''模拟登陆,获取认证的后的session''' req = urllib2.Request(loginurl,self.post_data) _response = urllib2.urlopen(req) for i in str(_response.info()).split('\n'): if 'Set-Cookie' in i: sid = i.split("=")[1].split(";")[0][16:] break _d=_response.read() return _d,sid def getpagehtml(self,pageurl): '''''获取目标网站任意一个页面的html代码''' req2=urllib2.Request(pageurl,self.post_data) _response2=urllib2.urlopen(req2) status = _response2.code _d2=_response2.read() return _d2 def center(sql): try: center_ip = zabbix_server center_user = 'root' center_passwd = '123456789' conn = MySQLdb.connect(host = center_ip,user = center_user,passwd = center_passwd,connect_timeout=10) cursor = conn.cursor() cursor.execute(sql) alldata = cursor.fetchall() cursor.close() conn.close() return alldata except Exception,e: return '0' def operation(action,hostip,post_dirc): boss = web_form() #参递一个post参数 url = "http://%s/zabbix" % zabbix_server boss.post_data = urllib.urlencode({"autologin":"1","enter":"Sign in","name":"admin","password":"zabbix"}) login,sid = boss.login("%s/index.php" % url)#首先登陆zabbix,获取认证的sid if action == 'add':#添加主机 sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip hostid = center(sql) if len(hostid) != 0: print "Server %s is already in zabbix status !" % hostip else: 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} post_form = dict(post_form,**post_dirc) boss.post_data=urllib.urlencode(post_form) add_host = boss.getpagehtml("%s/hosts.php" % url) sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip hostid = center(sql) if len(hostid) != 0: print "Add %s in zabbix success !" % hostip else: print "Add %s in zabbix failure !" % hostip elif action == 'del':#删除主机 sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip hostid = center(sql)#从zabbix服务器端数据库取出要删除ip的hostid号 if len(hostid) != 0: hostid = hostid[0][0] a = 'hosts[%s]' % hostid boss.post_data=urllib.urlencode({'form_refresh':'1','go':'delete','goButton':'确认 (1)',a:hostid,'sid':sid}) del_host = boss.getpagehtml("%s/hosts.php" % url) hostid = center(sql) sql = "SELECT hostid FROM zabbix.hosts WHERE host='%s'" % hostip if len(hostid) != 0: print "Delete %s from zabbix failure !" % hostip else: print "Delete %s from zabbix success !" % hostip else: print "Server %s not in zabbix status !" % hostip def main(block,action,hostip):#根据IP的应用,确定需要添加到zabbix中的组和需要应用的模板 if block == "adb" or block == "ldb" or block == "ccs": sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('WD_ADB_LDB','Linux servers')" groupdata = center(sql) sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','MySQL_status','Linux_disk_io')" templates = center(sql) elif "_s" in block: sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('Linux servers','WD_SLAVE')" groupdata = center(sql) sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','MySQL_status','Slave_Status','Linux_disk_io')" templates = center(sql) else: sql = "SELECT groupid,name FROM zabbix.groups WHERE name IN ('Linux servers','WD_GS')" groupdata = center(sql) sql = "SELECT hostid,HOST FROM zabbix.hosts WHERE HOST IN ('linux_Server','Linux_disk_io')" templates = center(sql) templatesdirc = {} groupdirc = {} for i in groupdata: groups = 'groups[%s]' % str(i[0]) groupdirc[groups] = str(i[0]) for i in templates: groups = 'templates[%s]' % str(i[0]) templatesdirc[groups] = str(i[1]) post_dirc = dict(groupdirc,**templatesdirc) operation(action,hostip,post_dirc) if __name__=="__main__": block = 'adb_s' hostip = '6.6.6.6' action = 'add' action = 'del' main(block,action,hostip)
本文出自 “王伟” 博客,请务必保留此出处http://wangwei007.blog.51cto.com/68019/1139982
相关文章推荐
- zabbix_server的自动发现,实现批量添加主机,并链接到模板
- Zabbix应用--自动添加客户端主机
- shell脚本添加和删除apahce虚拟主机并判断是否正常
- zabbix主动模式和被动模式-添加监控主机-添加自定义模板- 处理图形中的乱码-自动发现
- 刷新SQL Server所有视图、函数、存储过程 更多 sql 此脚本用于在删除或添加字段时刷新相关视图,并检查视图、函数、存储过程有效性。 [SQL]代码 --视图、存储过程、函数名称 DECLARE @NAME NVARCHAR(255); --局部游标 DECLARE @CUR CURSOR --自动修改未上状态为旷课 SET @CUR=CURSOR SCROLL DYNAMIC FO
- Python实现自动添加脚本头信息的示例代码
- Zabbix添加\删除主机
- zabbix监控主动模式、被动模式、添加监控主机、添加自定义模板、处理图形乱码、自动发现
- zabbix的使用自动发现和api添加主机
- python调用zabbix的api接口添加主机、查询组、主机、模板
- 基于python的添加和删除安全组的脚本
- Python实现自动添加脚本头信息的示例代码
- python批量添加zabbix Screens的两个脚本分享
- Zabbix之Python脚本端口自动发现
- zabbix的主动模式和被动模式、添加监控主机、添加自定义模板、处理图形中的乱码、自动发现
- python调用zabbix api 实现主机添加等功能
- zabbix学习(二)自动发现主机并添加主机
- 【python初学】自动删除目录下空文件夹脚本
- (windows)python脚本:自动备份并压缩文件,同时删除过期文件
- python调用zabbix的api接口添加主机、查询组、主机、模板