Python一键添加Zabbix监控脚本

cheng029

　　   由于时间关系没有在脚本里把创建主机组和模板的功能，只是单单实现了添加主机的功能 zabbix_tools.py
　　

　　#!/usr/bin/python
　　#coding:utf-8
　　import json
　　import urllib2
　　from urllib2 import URLError
　　import sys
　　class ZabbixTools:
　　def __init__(self):
　　self.url = 'http://lihuipeng.blog.运维网.com/zabbix/api_jsonrpc.php'
　　self.header = {"Content-Type":"application/json"}
　　def user_login(self):
　　data = json.dumps({
　　"jsonrpc": "2.0",
　　"method": "user.login",
　　"params": {
　　"user": "Admin",
　　"password": "lihuipeng"
　　},
　　"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 "Auth Failed, please Check your name and password:", e.code
　　else:
　　response = json.loads(result.read())
　　result.close()
　　#print response['result']
　　self.authID = response['result']
　　return self.authID
　　def host_get(self):
　　data = json.dumps({
　　"jsonrpc":"2.0",
　　"method":"host.get",
　　"params":{
　　"output":["hostid","name"],
　　"filter":{"host":""}
　　},
　　"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())
　　result.close()
　　print "Number Of Hosts: ", len(response['result'])
　　for host in response['result']:
　　print "Host ID:",host['hostid'],"Host Name:",host['name']
　　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:
　　response = json.loads(result.read())
　　result.close()
　　print "hostgroup : %s ------ id : %s" % (response['result'][0]['name'], response['result'][0]['groupid'])
　　self.hostgroupID = response['result'][0]['groupid']
　　return response['result'][0]['groupid']
　　def template_get(self, templateName):
　　data = json.dumps({
　　"jsonrpc":"2.0",
　　"method": "template.get",
　　"params": {
　　"output": "extend",
　　"filter": {
　　"host": [
　　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 "template : %s ------ id : %s" % (response['result'][0]['name'], response['result'][0]['templateid'])
　　self.templateID = response['result'][0]['templateid']
　　return response['result'][0]['templateid']
　　def host_create(self, hostip, hostgroupName, templateName):
　　data = json.dumps({
　　"jsonrpc":"2.0",
　　"method":"host.create",
　　"params":{
　　"host": hostip,
　　"interfaces": [
　　{
　　"type": 1,
　　"main": 1,
　　"useip": 1,
　　"ip": hostip,
　　"dns": "",
　　"port": "10050"
　　}
　　],
　　"groups": [
　　{
　　"groupid": self.hostgroup_get(hostgroupName)
　　}
　　],
　　"templates": [
　　{
　　"templateid": self.template_get(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 "host : %s ------ id : %s" % (hostip, response['result']['hostids'])
　　self.hostid = response['result']['hostids']
　　return response['result']['hostids']
　　if __name__ == "__main__":
　　if len(sys.argv) != 4:
　　print "Usage: %s ip hostgroupName templateName" % sys.argv[0]
　　sys.exit(1)
　　test = ZabbixTools()
　　test.host_create(sys.argv[1], sys.argv[2], sys.argv[2])
　　

　　user_login  是帐号密码验证
　　host_get    是列出监控机  
　　hostgroup_get  是获取主机组的ID
　　template_get   是获取模板的ID
　　host_create    添加主机
　　运行方式：（前提是test-group这个主机组和test-template这个模板必须存在）
　　./zabbix_tools.py  192.168.3.100  test-group  test-template