当前位置:   article > 正文

zabbix 批量添加主机_zabbix批量导入主机

zabbix批量导入主机

zabbix 批量添加主机

1.1::通过本教程起到抛砖引玉效果,希望各位朋友受益良多。

1.2::如您有任何问题请联系作者,QQ1284524409。

1.3::以下提供的任何软件仅供学习交流使用。

1.4::**项目地址**

最新api批量操作项目地址


#!/usr/bin/python
# coding:utf-8
  
import json
import urllib2
from urllib2 import URLError
import sys, argparse
import xlrd

defaultencoding = 'utf-8'
if sys.getdefaultencoding() != defaultencoding:
    reload(sys)
    sys.setdefaultencoding(defaultencoding)
  
class zabbix_api:
    def __init__(self):
        self.url = 'http://127.0.0.1/zabbix/api_jsonrpc.php'  # 修改URL
        self.header = {"Content-Type":"application/json"}
        self.user_login()

    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, self.header)
        try:
            result = urllib2.urlopen(request, timeout = 2)
        except URLError as e:
            print u"\033[041m地址请求失败请检查!\033[0m \n\033[041m%s!\033[0m" % e
            sys.exit(1)
        else:
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                self.authID = response['result']
            elif response.get('error','') != '':
                print u"\033[041m用户认证失败请检查!\033[0m \n\033[041m%s\033[0m" % (response['error']['data'])
                sys.exit(1)
    #![01_创建模板]
    def template_get(self, templateName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"template.get",
                            "params":{
                                    "output": "extend",
                                    "filter": {
                                                "host": templateName
                                            }
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['templateid']
        else:
            return response['result']
                    
    def template_create(self, templateName):
        default_id = {}
        default_id['groupid'] = self.hostGroup_get('000_LocalTemplates')
        if default_id['groupid'] == []:
            self.hostGroup_create('000_LocalTemplates')
            default_id['groupid'] = self.hostGroup_get('000_LocalTemplates')
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['templateid'] = self.template_get(name_list_1[n_2]['name'])
            if id_2['templateid'] != []:
                print u"创建模板 : \033[041m%s\033[0m 失败!,模板重复创建" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "template.create",
                                "params": {
                                            "host": name_list_2[n_3]['name'],
                                            "groups": {
                                                        "groupid": default_id['groupid']
                                                    },
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"创建模板 : \033[042m%s\033[0m 成功!,模板ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['templateids']))
            elif response.get('error','') != '':
                print u"创建模板 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])

    def template_delete(self, templateName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        id_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['templateids'] = self.template_get(name_list_1[n_2]['name'])
            if id_2['templateids'] == []:
                print u"删除模板 : \033[041m%s\033[0m 失败!,模板不存在!" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
            id_list_2.append(id_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "template.delete",
                                "params": [
                                            id_list_2[n_3]['templateids']
                                        ],
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"删除模板 : \033[042m%s\033[0m 成功!,模板ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['templateids']))
            elif response.get('error','') != '':
                print u"删除模板 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])
    #![02_为模板创建应用集]
    def application_get(self, templateName, applicationName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"application.get",
                            "params":{
                                    "output": "extend",
                                    "hostids": self.template_get(templateName),
                                    "filter":{
                                            "name": applicationName
                                        },
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['applicationid']
        else:
            return response['result']

    def application_create(self, templateName, applicationName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in applicationName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为模板删除应用集失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['templateid'] = self.template_get(name_list_1[n_3]['name'])
            if id_3['templateid'] == []:
                print u"为模板 : \033[041m%s\033[0m 创建应用集失败!,\033[041m模板不存在\033[0m" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4_1 = []
        id_list_4_2 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4_1 = {}
            id_4_2 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4_1['templateid'] = id_list_3[n_4]['templateid']
            id_4_2['applicationid'] = self.application_get(name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'])
            if id_4_2['applicationid'] != []:
                print u"为模板 : \033[041m%s\033[0m 创建应用集 : \033[041m%s\033[0m 失败!,\033[041m应用集已存在!\033[0m" % \
                (name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'])
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4_1.append(id_4_1)
            id_list_4_2.append(id_4_2)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "application.create",
                                "params": {
                                            "name": name_list_4_2[n_5]['name'],
                                            "hostid": id_list_4_1[n_5]['templateid'],
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 创建应用集 : \033[042m%s\033[0m 成功!,并且应用集ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['applicationids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 创建应用集 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], response['error']['data'])

    def application_delete(self, templateName, applicationName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in applicationName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为模板删除应用集失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['templateid'] = self.template_get(name_list_1[n_3]['name'])
            if id_3['templateid'] == []:
                print u"为模板 : \033[041m%s\033[0m 删除应用集失败!,模板不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4['applicationid'] = self.application_get(name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'])
            if id_4['applicationid'] == []:
                print u"为模板删除应用集失败!,\033[041m应用集不存在\033[0m !"
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4.append(id_4)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "application.delete",
                                "params": [
                                            id_list_4[n_5]['applicationid']
                                        ],
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 删除应用集 : \033[042m%s\033[0m 成功!,并且应用集ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['applicationids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 删除应用集 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], response['error']['data'])
    #![03_为模板创建监控项]
    def item_get(self, templateName, itemName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"item.get",
                            "params":{
                                    "output": "extend",
                                    "hostids": self.template_get(templateName),
                                    "filter":{
                                            "name": itemName
                                        },
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['itemid']
        else:
            return response['result']
              
    def item_create(self, templateName, itemApplication, itemName, itemKey, itemValueType, itemDely):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in itemApplication.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        name_list_3 = []
        for n_3 in itemName.split('//'):
            name_3 = {}
            name_3['name'] = n_3
            name_list_3.append(name_3)
        name_list_4 = []
        for n_4 in itemKey.split('//'):
            name_4 = {}
            name_4['name'] = n_4
            name_list_4.append(name_4)
        name_list_5 = []
        for n_5 in itemValueType.split('//'):
            name_5 = {}
            name_5['name'] = n_5
            name_list_5.append(name_5)
        name_list_6 = []
        for n_6 in itemDely.split('//'):
            name_6 = {}
            name_6['name'] = n_6
            name_list_6.append(name_6)  
        if len(name_list_1) != len(name_list_2) or \
        len(name_list_1) != len(name_list_3) or \
        len(name_list_1) != len(name_list_4) or \
        len(name_list_1) != len(name_list_5) or \
        len(name_list_1) != len(name_list_6):
            print u"为模板创建监控项失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_7_1 = []
        name_list_7_2 = []
        name_list_7_3 = []
        name_list_7_4 = []
        name_list_7_5 = []
        name_list_7_6 = []
        id_list_7 = []
        for n_7 in range(len(name_list_1)):
            name_7_1 = {}
            name_7_2 = {}
            name_7_3 = {}
            name_7_4 = {}
            name_7_5 = {}
            name_7_6 = {}
            id_7 = {}
            name_7_1['name'] = name_list_1[n_7]['name']
            name_7_2['name'] = name_list_2[n_7]['name']
            name_7_3['name'] = name_list_3[n_7]['name']
            name_7_4['name'] = name_list_4[n_7]['name']
            name_7_5['name'] = name_list_5[n_7]['name']
            name_7_6['name'] = name_list_6[n_7]['name']
            id_7['templateid'] = self.template_get(name_list_1[n_7]['name'])
            if id_7['templateid'] == []:
                print u"为模板 : \033[041m%s\033[0m 创建监控项失败!,模板不存在" % name_list_1[n_7]['name']
                continue
            name_list_7_1.append(name_7_1)
            name_list_7_2.append(name_7_2)
            name_list_7_3.append(name_7_3)
            name_list_7_4.append(name_7_4)
            name_list_7_5.append(name_7_5)
            name_list_7_6.append(name_7_6)
            id_list_7.append(id_7)
        name_list_8_1 = []
        name_list_8_2 = []
        name_list_8_3 = []
        name_list_8_4 = []
        name_list_8_5 = []
        name_list_8_6 = []
        id_list_8_1 = []
        id_list_8_2 = []
        for n_8 in range(len(name_list_1)):
            name_8_1 = {}
            name_8_2 = {}
            name_8_3 = {}
            name_8_4 = {}
            name_8_5 = {}
            name_8_6 = {}
            id_8_1 = {}
            id_8_2 = {}
            name_8_1['name'] = name_list_7_1[n_8]['name']
            name_8_2['name'] = name_list_7_2[n_8]['name']
            name_8_3['name'] = name_list_7_3[n_8]['name']
            name_8_4['name'] = name_list_7_4[n_8]['name']
            name_8_5['name'] = name_list_7_5[n_8]['name']
            name_8_6['name'] = name_list_7_6[n_8]['name']
            id_8_1['templateid'] = id_list_7[n_8]['templateid']
            id_8_2['applicationid'] = self.application_get(name_list_7_1[n_8]['name'], name_list_7_2[n_8]['name'])
            if id_8_2['applicationid'] == []:
                print u"为监控项 : \033[041m%s\033[0m 附加应用集 : \033[041m%s\033[0m 失败!,应用集不存在" % \
                (name_list_7_3[n_8]['name'], name_list_7_2[n_8]['name'])
                continue
            name_list_8_1.append(name_8_1)
            name_list_8_2.append(name_8_2)
            name_list_8_3.append(name_8_3)
            name_list_8_4.append(name_8_4)
            name_list_8_5.append(name_8_5)
            name_list_8_6.append(name_8_6)
            id_list_8_1.append(id_8_1)
            id_list_8_2.append(id_8_2)
        name_list_9_1 = []
        name_list_9_2 = []
        name_list_9_3 = []
        name_list_9_4 = []
        name_list_9_5 = []
        name_list_9_6 = []
        id_list_9_1 = []
        id_list_9_2 = []
        for n_9 in range(len(name_list_1)):
            name_9_1 = {}
            name_9_2 = {}
            name_9_3 = {}
            name_9_4 = {}
            name_9_5 = {}
            name_9_6 = {}
            id_9_1 = {}
            id_9_2 = {}
            id_9_3 = {}
            name_9_1['name'] = name_list_8_1[n_9]['name']
            name_9_2['name'] = name_list_8_2[n_9]['name']
            name_9_3['name'] = name_list_8_3[n_9]['name']
            name_9_4['name'] = name_list_8_4[n_9]['name']
            name_9_5['name'] = name_list_8_5[n_9]['name']
            name_9_6['name'] = name_list_8_6[n_9]['name']
            id_9_1['templateid'] = id_list_8_1[n_9]['templateid']
            id_9_2['applicationid'] = id_list_8_2[n_9]['applicationid']
            id_9_3['itemid'] = self.item_get(name_list_8_1[n_9]['name'], name_list_8_3[n_9]['name'])
            if id_9_3['itemid'] != []:
                print u"为模板 : \033[041m%s\033[0m 创建监控项失败!,监控项 : \033[041m%s\033[0m 已存在,并且监控项ID为 : \033[041m%s\033[0m" % \
                    (name_list_8_1[n_9]['name'], name_list_8_3[n_9]['name'], id_9_3['itemid'])
                continue
            name_list_9_1.append(name_9_1)
            name_list_9_2.append(name_9_2)
            name_list_9_3.append(name_9_3)
            name_list_9_4.append(name_9_4)
            name_list_9_5.append(name_9_5)
            name_list_9_6.append(name_9_6)
            id_list_9_1.append(id_9_1)
            id_list_9_2.append(id_9_2)
        for n_10 in range(len(name_list_9_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "item.create",
                                "params": {
                                            "hostid": id_list_9_1[n_10]['templateid'],
                                            "applications": [id_list_9_2[n_10]['applicationid']],
                                            "name": name_list_9_3[n_10]['name'],
                                            "type": 7,
                                            "key_": name_list_9_4[n_10]['name'],
                                            "value_type": name_list_9_5[n_10]['name'],
                                            "delay": name_list_9_6[n_10]['name']
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 创建监控项 : \033[042m%s\033[0m 成功!,并且监控项ID为 : \033[042m%s\033[0m" % \
                (name_list_9_1[n_10]['name'], name_list_9_3[n_10]['name'], ",".join(response['result']['itemids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 创建监控项 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_9_1[n_10]['name'], name_list_9_3[n_10]['name'], response['error']['data'])

    def item_delete(self, templateName, itemName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in itemName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为模板删除应用集失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['templateid'] = self.template_get(name_list_1[n_3]['name'])
            if id_3['templateid'] == []:
                print u"为模板 : \033[041m%s\033[0m 删除监控项失败!,模板不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4['itemid'] = self.item_get(name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'])
            if id_4['itemid'] == []:
                print u"为模板 : \033[041m%s\033[0m 删除监控项 : \033[041m%s\033[0m 失败!,\033[041m监控项不存在\033[0m !" %\
                (name_list_4_1[n_4]('name'), name_list_4_2[n_4]('name'))
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4.append(id_4)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "item.delete",
                                "params": [
                                            id_list_4[n_5]['itemid']
                                        ],
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 删除监控项 : \033[042m%s\033[0m 成功!,并且应监控项ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['itemids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 删除监控项 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], response['error']['data'])
    #![04_为模板创建触发器]
    def trigger_get(self, templateName, descriptionName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"trigger.get",
                            "params":{
                                    "output": "extend",
                                    "templateids": self.template_get(templateName),
                                    "filter":{
                                            "description": descriptionName
                                        },
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['triggerid']
        else:
            return response['result']

    def trigger_create(self, templateName, itemName, descriptionName, expressionName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in itemName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        name_list_3 = []
        for n_3 in descriptionName.split('//'):
            name_3 = {}
            name_3['name'] = n_3
            name_list_3.append(name_3)
        name_list_4 = []
        for n_4 in expressionName.split('//'):
            name_4 = {}
            name_4['name'] = n_4
            name_list_4.append(name_4)
        if len(name_list_1) != len(name_list_2) or \
        len(name_list_1) != len(name_list_3) or \
        len(name_list_1) != len(name_list_4):
            print u"为模板创建触发器失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_5_1 = []
        name_list_5_2 = []
        name_list_5_3 = []
        name_list_5_4 = []
        for n_5 in range(len(name_list_1)):
            name_5_1 = {}
            name_5_2 = {}
            name_5_3 = {}
            name_5_4 = {}
            id_5 = {}
            name_5_1['name'] = name_list_1[n_5]['name']
            name_5_2['name'] = name_list_2[n_5]['name']
            name_5_3['name'] = name_list_3[n_5]['name']
            name_5_4['name'] = name_list_4[n_5]['name']
            id_5['templateid'] = self.template_get(name_list_1[n_5]['name'])
            if id_5['templateid'] == []:
                print u"为模板 : \033[041m%s\033[0m 的监控项创建触发器失败!,模板不存在"  % name_list_1[n_5]['name']
                continue
            name_list_5_1.append(name_5_1)
            name_list_5_2.append(name_5_2)
            name_list_5_3.append(name_5_3)
            name_list_5_3.append(name_5_3)
            name_list_5_4.append(name_5_4)
        name_list_6_1 = []
        name_list_6_2 = []
        name_list_6_3 = []
        name_list_6_4 = []
        for n_6 in range(len(name_list_5_1)):
            name_6_1 = {}
            name_6_2 = {}
            name_6_3 = {}
            name_6_4 = {}
            id_6 = {}
            name_6_1['name'] = name_list_5_1[n_6]['name']
            name_6_2['name'] = name_list_5_2[n_6]['name']
            name_6_3['name'] = name_list_5_3[n_6]['name']
            name_6_4['name'] = name_list_5_4[n_6]['name']
            id_6['itemid'] = self.item_get(name_list_5_1[n_6]['name'], name_list_5_2[n_6]['name'])
            if id_6['itemid'] == []:
                print u"为模板 : \033[041m%s\033[0m 的监控项 : \033[041m%s\033[0m 创建触发器失败!,监控项不存在" % \
                (name_list_5_1[n_6]['name'], name_list_5_2[n_6]['name'])
                continue
            name_list_6_1.append(name_6_1)
            name_list_6_2.append(name_6_2)
            name_list_6_3.append(name_6_3)
            name_list_6_4.append(name_6_4)
        name_list_7_1 = []
        name_list_7_2 = []
        name_list_7_3 = []
        name_list_7_4 = []
        for n_7 in range(len(name_list_5_1)):
            name_7_1 = {}
            name_7_2 = {}
            name_7_3 = {}
            name_7_4 = {}
            id_7 = {}
            name_7_1['name'] = name_list_5_1[n_7]['name']
            name_7_2['name'] = name_list_5_2[n_7]['name']
            name_7_3['name'] = name_list_5_3[n_7]['name']
            name_7_4['name'] = name_list_5_4[n_7]['name']
            id_7['description'] = self.trigger_get(name_list_5_1[n_7]['name'], name_list_5_3[n_7]['name'])
            if id_7['description'] != []:
                print u"为模板 : \033[041m%s\033[0m 的监控项 : \033[041m%s\033[0m 创建触发器失败!,触发器 : \033[041m%s\033[0m 已存在,并且触发器ID为 : \033[041m%s\033[0m" % \
                (name_list_5_1[n_7]['name'], name_list_5_2[n_7]['name'], name_list_5_3[n_7]['name'], id_7['description'])
                continue
            name_list_7_1.append(name_7_1)
            name_list_7_2.append(name_7_2)
            name_list_7_3.append(name_7_3)
            name_list_7_4.append(name_7_4)
        for n_8 in range(len(name_list_7_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "trigger.create",
                                "params": {
                                            "description": name_list_7_3[n_8]['name'],
                                            "expression": name_list_7_4[n_8]['name'],
                                            "priority": 5,
                                            "manual_close": 1
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 的监控项 : \033[042m%s\033[0m 创建触发器 : \033[042m%s\033[0m 成功!,并且触发器ID为 : \033[042m%s\033[0m" % \
                (name_list_7_1[n_8]['name'], name_list_7_2[n_8]['name'], name_list_7_3[n_8]['name'], ",".join(response['result']['triggerids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 的监控项 : \033[041m%s\033[0m 创建触发器 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_7_1[n_8]['name'], name_list_7_2[n_8]['name'], name_list_7_3[n_8]['name'], response['error']['data'])
                
    def trigger_delete(self, templateName, descriptionName):
        name_list_1 = []
        for n_1 in templateName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in descriptionName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为模板删除应用集失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['triggerid'] = self.trigger_get(name_list_1[n_3]['name'], name_list_2[n_3]['name'])
            if id_3['triggerid'] == []:
                print u"为模板 : \033[041m%s\033[0m 删除触发器 : \033[041m%s\033[0m 失败!,\033[041m触发器不存在\033[0m !" % \
                (name_list_1[n_3]['name'], name_list_2[n_3]['name'])
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        for n_4 in range(len(name_list_3_1)):
            data = json.dumps({
                                "jsonrpc":"2.0",
                                "method":"trigger.delete",
                                "params":[
                                            id_list_3[n_4]['triggerid']
                                        ],
                                "auth":self.authID,
                                "id":1,
                            })
            request = urllib2.Request(self.url, data, self.header)     
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为模板 : \033[042m%s\033[0m 删除触发器 : \033[042m%s\033[0m 成功!,并且触发器ID为 : \033[042m%s\033[0m" % \
                (name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'], ",".join(response['result']['triggerids']))
            elif response.get('error','') != '':
                print u"为模板 : \033[041m%s\033[0m 删除触发器 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_3_1[n_4]['name'], name_list_3_2[n_4]['name'], response['error']['data'])
    #![05_创建主机]
    def host_get(self, hostName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"host.get",
                            "params":{
                                    "output": "extend",
                                    "filter": {
                                                "host": hostName
                                            },
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['hostid']
        else:
            return response['result']

    def host_create(self, hostName):
        default_id = {}
        default_id['groupid'] = self.hostGroup_get('000_LocalHost')
        if default_id['groupid'] == []:
            self.hostGroup_create('000_LocalHost')
            default_id['groupid'] = self.hostGroup_get('000_LocalHost')
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['hostid'] = self.host_get(name_list_1[n_2]['name'])
            if id_2['hostid'] != []:
                print u"创建主机 : \033[041m%s\033[0m 失败!,主机重复创建" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                               "jsonrpc":"2.0",
                               "method":"host.create",
                               "params":{
                                         "host": name_list_2[n_3]['name'],
                                         "interfaces": [
                                                            {
                                                                "type": 1,
                                                                "main": 1,
                                                                "useip": 1,
                                                                "ip": "127.0.0.1",
                                                                "dns": "",
                                                                "port": "10050"
                                                            }
                                                        ],
                                        "groups": [
                                                        {
                                                            "groupid": default_id['groupid']
                                                        }
                                                   ],
                                         },
                               "auth": self.authID,
                               "id":1                  
            })
            request = urllib2.Request(self.url, data, self.header)  
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"创建主机 : \033[042m%s\033[0m 成功!,主机ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"创建主机 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])

    def host_delete(self, hostName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        id_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['hostid'] = self.host_get(name_list_1[n_2]['name'])
            if id_2['hostid'] == []:
                print u"删除主机组 : \033[041m%s\033[0m 失败!,主机组不存在" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
            id_list_2.append(id_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "host.delete",
                                "params": [
                                            id_list_2[n_3]['hostid']
                                        ],
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"删除主机 : \033[042m%s\033[0m 成功!,主机组ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"删除主机 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])
    #![06_为主机创建接口]
    def interface_get(self, hostName, ipName, portName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"hostinterface.get",
                            "params":{
                                    "output": "extend",
                                    "hostids": self.host_get(hostName),
                                    "filter":{
                                            "ip": ipName,
                                            "port": portName
                                        },
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)     
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['interfaceid']
        else:
            return response['result']

    def interface_massadd(self, hostName, ipName, portName, defaultName, typeName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in ipName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        name_list_3 = []
        for n_3 in portName.split('//'):
            name_3 = {}
            name_3['name'] = n_3
            name_list_3.append(name_3)
        name_list_4 = []
        for n_4 in defaultName.split('//'):
            name_4 = {}
            name_4['name'] = n_4
            name_list_4.append(name_4)
        name_list_5 = []
        for n_5 in typeName.split('//'):
            name_5 = {}
            name_5['name'] = n_5
            name_list_5.append(name_5)  
        if len(name_list_1) != len(name_list_2) or \
        len(name_list_1) != len(name_list_3) or \
        len(name_list_1) != len(name_list_4) or \
        len(name_list_1) != len(name_list_5):
            print u"为主机附加接口失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_6_1 = []
        name_list_6_2 = []
        name_list_6_3 = []
        name_list_6_4 = []
        name_list_6_5 = []
        id_list_6 = []
        for n_6 in range(len(name_list_1)):
            name_6_1 = {}
            name_6_2 = {}
            name_6_3 = {}
            name_6_4 = {}
            name_6_5 = {}
            id_6 = {}
            name_6_1['name'] = name_list_1[n_6]['name']
            name_6_2['name'] = name_list_2[n_6]['name']
            name_6_3['name'] = name_list_3[n_6]['name']
            name_6_4['name'] = name_list_4[n_6]['name']
            name_6_5['name'] = name_list_5[n_6]['name']
            id_6['hostid'] = self.host_get(name_list_1[n_6]['name'])
            if id_6['hostid'] == []:
                print u"为主机附加接口失败!,主机 : \033[041m%s\033[0m 不存在" % name_list_1[n_6]['name']
                continue
            name_list_6_1.append(name_6_1)
            name_list_6_2.append(name_6_2)
            name_list_6_3.append(name_6_3)
            name_list_6_4.append(name_6_4)
            name_list_6_5.append(name_6_5)
            id_list_6.append(id_6)
        name_list_7_1 = []
        name_list_7_2 = []
        name_list_7_3 = []
        name_list_7_4 = []
        name_list_7_5 = []
        id_list_7 = []
        for n_7 in range(len(name_list_1)):
            name_7_1 = {}
            name_7_2 = {}
            name_7_3 = {}
            name_7_4 = {}
            name_7_5 = {}
            id_7_1 = {}
            id_7_2 = {}
            name_7_1['name'] = name_list_1[n_7]['name']
            name_7_2['name'] = name_list_2[n_7]['name']
            name_7_3['name'] = name_list_3[n_7]['name']
            name_7_4['name'] = name_list_4[n_7]['name']
            name_7_5['name'] = name_list_5[n_7]['name']
            id_7_1['hostid'] = id_list_6[n_7]['hostid']
            id_7_2['interfaceid'] = self.interface_get(name_list_1[n_7]['name'], name_list_2[n_7]['name'], name_list_3[n_7]['name'])
            if id_7_2['interfaceid'] != []:
                print u"为主机 : \033[041m%s\033[0m 附加接口失败!,接口 : \033[041m%s\033[0m 已存在,并且接口ID为 : \033[042m%s\033[0m" % \
                    (name_list_1[n_7]['name'], name_list_3[n_7]['name'], id_7_2['interfaceid'])
                continue
            name_list_7_1.append(name_7_1)
            name_list_7_2.append(name_7_2)
            name_list_7_3.append(name_7_3)
            name_list_7_4.append(name_7_4)
            name_list_7_5.append(name_7_5)
            id_list_7.append(id_7_1)
        for n_8 in range(len(name_list_7_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "hostinterface.massadd",
                                "params": {
                                            "hosts": [
                                                        {
                                                            "hostid": id_list_7[n_8]['hostid']
                                                        }
                                                ],
                                            "interfaces": [
                                                            {
                                                                "dns": "",                                                                    
                                                                "ip": name_list_7_2[n_8]['name'],
                                                                "main": name_list_7_4[n_8]['name'],
                                                                "port": name_list_7_3[n_8]['name'],
                                                                "type": name_list_7_5[n_8]['name'],
                                                                "useip": 1,
                                                            }
                                                        ],
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 附加接口 : \033[042m%s\033[0m 成功!,并且接口ID为 : \033[042m%s\033[0m" % \
                (name_list_7_1[n_8]['name'], name_list_7_3[n_8]['name'], ",".join(response['result']['interfaceids']['interfaceids']))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 附加接口 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_7_1[n_8]['name'],name_list_7_3[n_8]['name'], response['error']['data'])

    def interface_massRemove(self, hostName, ipName, portName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in ipName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        name_list_3 = []
        for n_3 in portName.split('//'):
            name_3 = {}
            name_3['name'] = n_3
            name_list_3.append(name_3)
        if len(name_list_1) != len(name_list_2) or \
        len(name_list_1) != len(name_list_3):
            print u"为主机移除接口失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_4_1 = []
        name_list_4_2 = []
        name_list_4_3 = []
        id_list_4 = []
        for n_4 in range(len(name_list_1)):
            name_4_1 = {}
            name_4_2 = {}
            name_4_3 = {}
            id_4 = {}
            name_4_1['name'] = name_list_1[n_4]['name']
            name_4_2['name'] = name_list_2[n_4]['name']
            name_4_3['name'] = name_list_3[n_4]['name']
            id_4['hostid'] = self.host_get(name_list_1[n_4]['name'])
            if id_4['hostid'] == []:
                print u"为主机 : \033[041m%s\033[0m 移除接口失败!,主机不存在" % name_list_1[n_4]['name']
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            name_list_4_3.append(name_4_3)
            id_list_4.append(id_4)
        name_list_5_1 = []
        name_list_5_2 = []
        name_list_5_3 = []
        id_list_5 = []
        for n_5 in range(len(name_list_1)):
            name_5_1 = {}
            name_5_2 = {}
            name_5_3 = {}
            id_5_1 = {}
            id_5_2 = {}
            name_5_1['name'] = name_list_1[n_5]['name']
            name_5_2['name'] = name_list_2[n_5]['name']
            name_5_3['name'] = name_list_3[n_5]['name']
            id_5_1['hostid'] = id_list_4[n_5]['hostid']
            id_5_2['interfaceid'] = self.interface_get(name_list_1[n_5]['name'], name_list_2[n_5]['name'], name_list_3[n_5]['name'])
            if id_5_2['interfaceid'] == []:
                print u"为主机 : \033[041m%s\033[0m 移除接口失败!,接口 : \033[041m%s\033[0m 不存在" % (name_list_1[n_5]['name'], name_list_3[n_5]['name'])
                continue
            name_list_5_1.append(name_5_1)
            name_list_5_2.append(name_5_2)
            name_list_5_3.append(name_5_3)
            id_list_5.append(id_5_1)       
        for n_6 in range(len(name_list_5_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "hostinterface.massremove",
                                "params": {
                                            "hosts": [
                                                        {
                                                            "hostids": id_list_5[n_6]['hostid']
                                                        }
                                                ],
                                            "interfaces": [
                                                            {
                                                                "dns": "",                                                                    
                                                                "ip": name_list_5_2[n_6]['name'],
                                                                "port": name_list_5_3[n_6]['name'],
                                                            }
                                                        ],
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 移除接口 : \033[042m%s\033[0m 成功!,并且接口ID为 : \033[042m%s\033[0m" % \
                (name_list_5_1[n_6]['name'], name_list_5_3[n_6]['name'], ",".join([str(i) for i in response['result']['interfaceids']]))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 移除接口 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_5_1[n_6]['name'], name_list_5_3[n_6]['name'], response['error']['data'])
    #![07_为主机关联模板]
    def host_massadd(self, hostName, templateName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in templateName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为主机附加模板失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['hostid'] = self.host_get(name_list_1[n_3]['name'])
            if id_3['hostid'] == []:
                print u"为主机 : \033[041m%s\033[0m 附加模板失败!,主机不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4_1 = []
        id_list_4_2 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4_1 = {}
            id_4_2 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4_1['hostid'] = id_list_3[n_4]['hostid']
            id_4_2['templateid'] = self.template_get(name_list_3_2[n_4]['name'])
            if id_4_2['templateid'] == []:
                print u"为主机附加模板 : \033[041m%s\033[0m 失败!,模板不存在!" % name_list_3_2[n_4]['name']
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4_1.append(id_4_1)
            id_list_4_2.append(id_4_2)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "host.massadd",
                                "params": {
                                            "hosts": [
                                                            {
                                                                "hostid": id_list_4_1[n_5]['hostid']
                                                            }
                                                        ],
                                            "templates": [
                                                        {
                                                            "templateid": id_list_4_2[n_5]['templateid']
                                                        }
                                                    ],
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 附加模板 : \033[042m%s\033[0m 成功!,并且主机ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 附加模板 : \033[041m%s\033[0m 失败!,并且主机ID为 : \033[041m%s\033[0m \
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], id_list_4_2[n_5]['templateid'], response['error']['data'])
    
    def host_massremove(self, hostName, templateName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in templateName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为主机附加模板失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['hostid'] = self.host_get(name_list_1[n_3]['name'])
            if id_3['hostid'] == []:
                print u"为主机 : \033[041m%s\033[0m 附加模板失败!,主机不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4_1 = []
        id_list_4_2 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4_1 = {}
            id_4_2 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4_1['hostid'] = id_list_3[n_4]['hostid']
            id_4_2['templateid'] = self.template_get(name_list_3_2[n_4]['name'])
            if id_4_2['templateid'] == []:
                print u"为主机附加模板 : \033[041m%s\033[0m 失败!,模板不存在!" % name_list_3_2[n_4]['name']
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4_1.append(id_4_1)
            id_list_4_2.append(id_4_2)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "host.massremove",
                                "params": {
                                            "hostids": [
                                                            id_list_4_1[n_5]['hostid']
                                                    ],
                                            "templateids_clear": id_list_4_2[n_5]['templateid']
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 移除模板 : \033[042m%s\033[0m 成功!,并且主机ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 移除模板 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], response['error']['data'])
    #![08_创建主机组]
    def hostGroup_get(self, hostGroupName):
        data = json.dumps({
                            "jsonrpc":"2.0",
                            "method":"hostgroup.get",
                            "params":{
                                    "output": "extend",
                                    "filter": {
                                                "name": hostGroupName
                                            }
                                    },
                            "auth":self.authID,
                            "id":1,
                        })
        request = urllib2.Request(self.url, data, self.header)   
        result = urllib2.urlopen(request)
        response = json.loads(result.read())
        result.close()
        if response.get('result','') != []:
            return response['result'][0]['groupid']
        else:
            return response['result']
             
    def hostGroup_create(self, hostGroupName):
        name_list_1 = []
        for n_1 in hostGroupName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['groupid'] = self.hostGroup_get(name_list_1[n_2]['name'])
            if id_2['groupid'] != []:
                print u"创建主机组 : \033[041m%s\033[0m 失败!,主机组重复创建" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "hostgroup.create",
                                "params": {
                                "name": name_list_2[n_3]['name']
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)  
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"创建主机组 : \033[042m%s\033[0m 成功!,主机组ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['groupids']))
            elif response.get('error','') != '':
                print u"创建主机组 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])   
 
    def hostGroup_delete(self, hostGroupName):
        name_list_1 = []
        for n_1 in hostGroupName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        id_list_2 = []
        for n_2 in range(len(name_list_1)):
            name_2 = {}
            id_2 = {}
            name_2['name'] = name_list_1[n_2]['name']
            id_2['groupid'] = self.hostGroup_get(name_list_1[n_2]['name'])
            if id_2['groupid'] == []:
                print u"删除主机组 : \033[041m%s\033[0m 失败!,主机组不存在" % name_list_1[n_2]['name']
                continue
            name_list_2.append(name_2)
            id_list_2.append(id_2)
        for n_3 in range(len(name_list_2)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "hostgroup.delete",
                                "params": [
                                            id_list_2[n_3]['groupid']
                                        ],
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"删除主机组 : \033[042m%s\033[0m 成功!,主机组ID为 : \033[042m%s\033[0m" % (name_list_2[n_3]['name'], ",".join(response['result']['groupids']))
            elif response.get('error','') != '':
                print u"删除主机组 : \033[041m%s\033[0m 失败!\n\033[041m%s\033[0m" % (name_list_2[n_3]['name'], response['error']['data'])
    #![09_为主机附加主机组]
    def hostGroup_massadd(self, hostName, hostGroupName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in hostGroupName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为主机附加主机组失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['hostid'] = self.host_get(name_list_1[n_3]['name'])
            if id_3['hostid'] == []:
                print u"为主机 : \033[041m%s\033[0m 附加主机组失败!,主机不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4_1 = []
        id_list_4_2 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4_1 = {}
            id_4_2 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4_1['hostid'] = id_list_3[n_4]['hostid']
            id_4_2['groupid'] = self.hostGroup_get(name_list_3_2[n_4]['name'])
            if id_4_2['groupid'] == []:
                print u"为主机附加主机组 : \033[041m%s\033[0m 失败!,主机组不存在!" % name_list_3_2[n_4]['name']
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4_1.append(id_4_1)
            id_list_4_2.append(id_4_2)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "host.massadd",
                                "params": {
                                            "hosts": [
                                                            {
                                                                "hostid": id_list_4_1[n_5]['hostid']
                                                            }
                                                        ],
                                            "groups": [
                                                        {
                                                            "groupid": id_list_4_2[n_5]['groupid']
                                                        }
                                                    ],
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 附加模板 : \033[042m%s\033[0m 成功!,并且主机ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 附加模板 : \033[041m%s\033[0m 失败!,并且主机ID为 : \033[041m%s\033[0m \
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], id_list_4_2[n_5]['groupid'], response['error']['data'])

    def hostGroup_massremove(self, hostName, hostGroupName):
        name_list_1 = []
        for n_1 in hostName.split('//'):
            name_1 = {}
            name_1['name'] = n_1
            name_list_1.append(name_1)
        name_list_2 = []
        for n_2 in hostGroupName.split('//'):
            name_2 = {}
            name_2['name'] = n_2
            name_list_2.append(name_2)
        if len(name_list_1) != len(name_list_2):
            print u"为主机移除主机组失败!,\033[041m输入的参数存在空值\033[0m"
            sys.exit(1)
        name_list_3_1 = []
        name_list_3_2 = []
        id_list_3 = []
        for n_3 in range(len(name_list_1)):
            name_3_1 = {}
            name_3_2 = {}
            id_3 = {}
            name_3_1['name'] = name_list_1[n_3]['name']
            name_3_2['name'] = name_list_2[n_3]['name']
            id_3['hostid'] = self.host_get(name_list_1[n_3]['name'])
            if id_3['hostid'] == []:
                print u"为主机 : \033[041m%s\033[0m 移除主机组失败!,主机不存在" % name_list_1[n_3]['name']
                continue
            name_list_3_1.append(name_3_1)
            name_list_3_2.append(name_3_2)
            id_list_3.append(id_3)
        name_list_4_1 = []
        name_list_4_2 = []
        id_list_4_1 = []
        id_list_4_2 = []
        for n_4 in range(len(name_list_3_1)):
            name_4_1 = {}
            name_4_2 = {}
            id_4_1 = {}
            id_4_2 = {}
            name_4_1['name'] = name_list_3_1[n_4]['name']
            name_4_2['name'] = name_list_3_2[n_4]['name']
            id_4_1['hostid'] = id_list_3[n_4]['hostid']
            id_4_2['groupid'] = self.hostGroup_get(name_list_3_2[n_4]['name'])
            if id_4_2['groupid'] == []:
                print u"为主机移除主机组 : \033[041m%s\033[0m 失败!,主机组不存在!" % name_list_3_2[n_4]['name']
                continue
            name_list_4_1.append(name_4_1)
            name_list_4_2.append(name_4_2)
            id_list_4_1.append(id_4_1)
            id_list_4_2.append(id_4_2)
        for n_5 in range(len(name_list_4_1)):
            data = json.dumps({
                                "jsonrpc": "2.0",
                                "method": "host.massremove",
                                "params": {
                                            "hostids": [
                                                            id_list_4_1[n_5]['hostid']
                                                    ],
                                            "groupids": id_list_4_2[n_5]['groupid']
                                        },
                                "auth": self.authID,
                                "id": 1
                            })
            request = urllib2.Request(self.url, data, self.header)
            result = urllib2.urlopen(request)
            response = json.loads(result.read())
            result.close()
            if response.get('result','') != '':
                print u"为主机 : \033[042m%s\033[0m 移除主机组 : \033[042m%s\033[0m 成功!,并且主机ID为 : \033[042m%s\033[0m" % \
                (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], ",".join(response['result']['hostids']))
            elif response.get('error','') != '':
                print u"为主机 : \033[041m%s\033[0m 移除主机组 : \033[041m%s\033[0m 失败!\
                \n\033[041m%s\033[0m" % (name_list_4_1[n_5]['name'],name_list_4_2[n_5]['name'], response['error']['data'])

if __name__ == "__main__":
    zabbix = zabbix_api()
    #![01_创建模板]
    parser = argparse.ArgumentParser(description='zabbix  api ', usage='%(prog)s [options]')
    parser.add_argument('-ct', nargs='+', metavar=('模板名称'), dest='ct', help=u"创建模板(多个可用//隔开)")
    parser.add_argument('-cte', nargs='?', metavar=('无参数'), dest='cte', default='cte', \
                        help=u"通过zabbix_api.xlsx的Sheet2表为A列的主机批量创建模板")
    parser.add_argument('-dt', metavar=('模板名称'), nargs='+', dest='dt', help=u"删除模板(多个可用//隔开)")
    parser.add_argument('-dte', nargs='?', metavar=('无参数'), dest='dte', default='dte', \
                        help=u"通过zabbix_api.xlsx的Sheet2表从A列批量删除模板")
    #![02_为模板创建应用集]
    parser.add_argument('-ca', nargs='+', metavar=('模板名称 应用集名称'), dest='ca', \
                        help=u"为模板(多个模板可用//隔开)创建应用集(多个应用集可用//隔开)")
    parser.add_argument('-cae', nargs='?', metavar=('无参数'), dest='cae',default='cae', \
                        help=u"通过zabbix_api.xlsx的Sheet5表为A列模板批量创建B列应用集")
    parser.add_argument('-da', nargs='+', metavar=('模板名称 应用集名称'), dest='da', \
                        help=u"为模板(多个模板可用//隔开)删除应用集(多个应用集可用//隔开)")
    parser.add_argument('-dae', nargs='?', metavar=('无参数'), dest='dae',default='dae', \
                        help=u"通过zabbix_api.xlsx的Sheet5表为A列模板批量删除B列应用集")
    #![03_为模板创建监控项]
    parser.add_argument('-ci', nargs='+', \
                        metavar=('模板名称 应用集名称 监控项名称 监控项键值 监控项信息类型 监控项更新间隔'), \
                        dest='ci', help=u"为模板(多个模板可用//隔开)创建监控项(多个监控项可用//隔开)")
    parser.add_argument('-cie', nargs='?', metavar=('无参数'), dest='cie',default='cie', \
                        help=u"通过zabbix_api.xlsx的Sheet5表为A列模板批量创建CDEF列监控项,并附加到B列应用集")
    parser.add_argument('-di', nargs='+', metavar=('模板名称 应用集名称'), dest='di', \
                        help=u"为模板(多个模板可用//隔开)删除监控项(多个监控项可用//隔开)")
    parser.add_argument('-die', nargs='?', metavar=('无参数'), dest='die',default='die', \
                        help=u"通过zabbix_api.xlsx的Sheet5表为A列模板批量删除C列监控项")
    #![04_为模板创建触发器]
    parser.add_argument('-ctg', nargs='+', \
                        metavar=('模板名称 监控项名称 触发器名称 触发器表达式'), \
                        dest='ctg', help=u"为监控项(多个监控项可用//隔开)创建触发器(多个触发器可用//隔开)")
    parser.add_argument('-ctge', nargs='?', metavar=('无参数'), dest='ctge',default='ctge', \
                        help=u"通过zabbix_api.xlsx的Sheet6表为A列模板的B列监控项批量创建CD列触发器")
    parser.add_argument('-dtg', nargs='+', metavar=('模板名称 触发器名称'), dest='dtg', \
                        help=u"为模板(多个模板可用//隔开)删除触发器(多个触发器可用//隔开)")
    parser.add_argument('-dtge', nargs='?', metavar=('无参数'), dest='dtge',default='dtge', \
                        help=u"通过zabbix_api.xlsx的Sheet6表为A列模板批量删除C列触发器")
    #![05_创建主机]
    parser.add_argument('-ch', nargs='+', metavar=('主机名称'), dest='ch', \
                        help=u"创建主机(多个可用//隔开)")
    parser.add_argument('-che', nargs='?', metavar=('无参数'), dest='che', default='che', \
                        help=u"通过zabbix_api.xlsx的Sheet4表从A列批量创建主机")
    parser.add_argument('-dh', nargs='+', metavar=('主机组名称'), dest='dh', help=u"删除主机组(多个可用//隔开)")
    parser.add_argument('-dhe', nargs='?', metavar=('无参数'), dest='dhe', default='dhe', \
                        help=u"通过zabbix_api.xlsx的Sheet1表从A列批量删除主机组")
    #![06_为主机创建接口]
    parser.add_argument('-mai', nargs='+', \
                        metavar=('主机名称 接口地址 接口端口 作为默认接口 接口类型'), \
                        dest='mai', help=u"为主机(多个主机可用//隔开)附加接口(多个接口可用//隔开)")
    parser.add_argument('-maie', nargs='?', metavar=('无参数'), dest='maie',default='maie', \
                        help=u"通过zabbix_api.xlsx的Sheet4表为A列主机批量附加BCDE列接口")
    parser.add_argument('-mri', nargs='+', metavar=('主机名称 接口地址 接口端口'), dest='mri', \
                        help=u"为主机(多个主机可用//隔开)移除接口(多个接口可用//隔开)")
    parser.add_argument('-mrie', nargs='?', metavar=('无参数'), dest='mrie', default='mrie', \
                        help=u"通过zabbix_api.xlsx的Sheet4表为A列主机批量移除BC列接口")
    #![07_为主机关联模板]
    parser.add_argument('-mat', nargs='+', metavar=('主机组名称 模板名称'), dest='mat', \
                        help=u"为主机(多个主机可用//隔开)附加模板(多个模板可用//隔开)")
    parser.add_argument('-mate', nargs='?', metavar=('无参数'), dest='mate',default='mate', \
                        help=u"通过zabbix_api.xlsx的Sheet3表为A列主机组批量附加B列模板")
    parser.add_argument('-mrt', nargs='+', metavar=('主机组名称 模板名称'), dest='mrt', \
                        help=u"为主机(多个主机可用//隔开)移除模板(多个模板可用//隔开)")
    parser.add_argument('-mrte', nargs='?', metavar=('无参数'), dest='mrte', default='mrte',\
                        help=u"通过zabbix_api.xlsx的Sheet3表为A列主机组批量移除B列模板")
    #![08_创建主机组]
    parser.add_argument('-cg', nargs='+', metavar=('主机组名称'), dest='cg', help=u"创建主机组(多个可用//隔开)")
    parser.add_argument('-cge', nargs='?', metavar=('无参数'), dest='cge', default='cge', \
                        help=u"通过zabbix_api.xlsx的Sheet1表从A列批量创建主机组")
    parser.add_argument('-dg', nargs='+', metavar=('主机组名称'), dest='dg', help=u"删除主机组(多个可用//隔开)")
    parser.add_argument('-dge', nargs='?', metavar=('无参数'), dest='dge', default='dge', \
                        help=u"通过zabbix_api.xlsx的Sheet1表从A列批量删除主机组")
    #![09_为主机附加主机组]
    parser.add_argument('-mag', nargs='+', metavar=('主机名称 模板名称'), dest='mag', \
                        help=u"为主机(多个主机可用//隔开)附加主机组(多个主机组可用//隔开)")
    parser.add_argument('-mage', nargs='?', metavar=('无参数'), dest='mage',default='mage', \
                        help=u"通过zabbix_api.xlsx的Sheet3表为A列主机批量附加B列主机组")
    parser.add_argument('-mrg', nargs='+', metavar=('主机组名称 模板名称'), dest='mrg', \
                        help=u"为主机(多个主机可用//隔开)移除主机组(多个主机组可用//隔开)")
    parser.add_argument('-mrge', nargs='?', metavar=('无参数'), dest='mrge', default='mrge',\
                        help=u"通过zabbix_api.xlsx的Sheet3表为A列主机组批量移除B列主机组")
    parser.add_argument('-v', '--version', action='version', version='%(prog)s 如有问题请联系作者QQ1284524409', help=u"如有问题请联系作者QQ1284524409")
    if len(sys.argv) == 1:
        print parser.print_help()
    else:
        args = parser.parse_args()
        #![01_创建模板]
        if args.ct:
            zabbix.template_create(args.ct[0])
        elif args.cte != 'cte':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[0].nrows):
                if row == 0:
                    continue
                else:
                    templateName = workbook.sheets()[0].cell(row, 0).value
                    if templateName == '':
                        break
                    try:
                        zabbix.template_create(templateName)
                    except Exception as e:
                        print u"Sheet2表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        elif args.dt:
            zabbix.template_delete(args.dt[0])
        elif args.dte != 'dte':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[0].nrows):
                if row == 0:
                    continue
                else:
                    templateName = workbook.sheets()[0].cell(row, 0).value
                    if templateName == '':
                        break
                    try:
                        zabbix.template_delete(templateName)
                    except Exception as e:
                        print u"Sheet2表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        #![02_为模板创建应用集]
        elif args.ca:
            zabbix.application_create(args.ca[0], args.ca[1])
        elif args.cae != 'cae':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[1].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[1].cell(x, 0).value
                    if templateName == '':
                        break
                    applicationName = workbook.sheets()[1].cell(x, 1).value
                    if applicationName == '':
                        break
                    try:
                        zabbix.application_create(templateName, applicationName)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        elif args.da:
            zabbix.application_delete(args.da[0], args.da[1])
        elif args.dae != 'dae':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[1].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[1].cell(x, 0).value
                    if templateName == '':
                        break
                    applicationName = workbook.sheets()[1].cell(x, 1).value
                    if applicationName == '':
                        break
                    try:
                        zabbix.application_delete(templateName, applicationName)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        #![03_为模板创建监控项]
        elif args.ci:
            zabbix.item_create(args.ci[0], args.ci[1], args.ci[2], args.ci[3], args.ci[4], args.ci[5])
        elif args.cie != 'cie':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[6].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[2].cell(x, 0).value
                    if templateName == '':
                        break
                    itemApplication = workbook.sheets()[2].cell(x, 1).value
                    if itemApplication == '':
                        break
                    itemName = workbook.sheets()[2].cell(x, 2).value
                    if itemName == '':
                        break
                    itemKey = workbook.sheets()[2].cell(x, 3).value
                    if itemKey == '':
                        break
                    itemValueType = workbook.sheets()[2].cell(x, 4).value
                    if itemValueType == '':
                        break
                    itemDely = workbook.sheets()[2].cell(x, 5).value
                    if itemDely == '':
                        break
                    try:
                        zabbix.item_create(templateName, itemApplication, itemName, itemKey, str(int(itemValueType)), itemDely)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        elif args.di:
            zabbix.item_delete(args.di[0], args.di[1])
        elif args.die != 'die':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[2].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[2].cell(x, 0).value
                    if templateName == '':
                        break
                    itemName = workbook.sheets()[2].cell(x, 1).value
                    if itemName == '':
                        break
                    try:
                        zabbix.item_delete(templateName, itemName)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        #![04_为模板创建触发器]
        elif args.ctg:
            zabbix.trigger_create(args.ctg[0], args.ctg[1], args.ctg[2], args.ctg[3])
        elif args.ctge != 'ctge':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[3].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[3].cell(x, 0).value
                    if templateName == '':
                        break
                    itemName = workbook.sheets()[3].cell(x, 1).value
                    if itemName == '':
                        break
                    descriptionName = workbook.sheets()[3].cell(x, 2).value
                    if descriptionName == '':
                        break
                    expressionName = workbook.sheets()[3].cell(x, 3).value
                    if expressionName == '':
                        break
                    try:
                        zabbix.trigger_create(templateName, itemName, descriptionName, expressionName)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        elif args.dtg:
            zabbix.trigger_delete(args.dtg[0], args.dtg[1])
        elif args.dtge != 'dtge':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for x in xrange(workbook.sheets()[3].nrows):
                if x == 0:
                    continue
                else:
                    templateName = workbook.sheets()[3].cell(x, 0).value
                    if templateName == '':
                        break
                    triggerName = workbook.sheets()[3].cell(x, 2).value
                    if triggerName == '':
                        break
                    try:
                        zabbix.trigger_delete(templateName, triggerName)
                    except Exception as e:
                        print u"Sheet5表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (x + 1, e)
                        sys.exit(1)
        #![05_创建主机]
        elif args.ch:
            zabbix.host_create(args.ch[0])
        elif args.che != 'che':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[4].nrows):
                if row == 0:
                    continue
                else:                    
                    hostName = workbook.sheets()[4].cell(row, 0).value
                    if hostName == '':
                        break
                    try:
                        zabbix.host_create(hostName)
                    except Exception as e:
                        print u"Sheet4表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        elif args.dh:
            zabbix.host_delete(args.dh[0])
        elif args.dhe != 'dhe':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[4].nrows):
                if row == 0:
                    continue
                else:
                    hosthost = workbook.sheets()[4].cell(row, 0).value
                    if hosthost == '':
                        break
                    try:
                        zabbix.host_delete(hosthost)
                    except Exception as e:
                        print u"Sheet4表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        #![06_为主机创建接口]
        elif args.mai:
            zabbix.interface_massadd(args.mai[0], args.mai[1], args.mai[2], args.mai[3], args.mai[4])
        elif args.maie != 'maie':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for col1 in xrange(workbook.sheets()[5].nrows):
                if col1 == 0:
                    continue
                else:
                    hostName = workbook.sheets()[5].cell(col1, 0).value
                    if hostName == '':
                        break
                    ipName = workbook.sheets()[5].cell(col1, 1).value
                    if ipName == '':
                        break
                    portName = workbook.sheets()[5].cell(col1, 2).value
                    if portName == '':
                        break
                    defaultName = workbook.sheets()[5].cell(col1, 3).value
                    if defaultName == '':
                        break
                    typeName = workbook.sheets()[5].cell(col1, 4).value
                    if typeName == '':
                        break
                    try:
                        zabbix.interface_massadd(hostName, ipName, str(int(portName)), str(int(defaultName)), str(int(typeName)))
                    except Exception as e:
                        print u"Sheet4表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (col1 + 1, e)
                        sys.exit(1)
        elif args.mri:
            zabbix.interface_massRemove(args.mri[0], args.mri[1], args.mri[2])
        elif args.mrie != 'mrie':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for col1 in xrange(workbook.sheets()[5].nrows):
                if col1 == 0:
                    continue
                else:
                    hostName = workbook.sheets()[5].cell(col1, 0).value
                    if hostName == '':
                        break
                    ipName = workbook.sheets()[5].cell(col1, 1).value
                    if ipName == '':
                        break
                    portName = workbook.sheets()[5].cell(col1, 2).value
                    if portName == '':
                        break
                    try:
                        zabbix.interface_massRemove(hostName, ipName, str(int(portName)))
                    except Exception as e:
                        print u"Sheet4表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (col1 + 1, e)
                        sys.exit(1)
        #![07_为主机关联模板]
        elif args.mat:
            zabbix.host_massadd(args.mat[0], args.mat[1])
        elif args.mate != 'mate':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for n_1 in xrange(workbook.sheets()[6].nrows):
                if n_1 == 0:
                    continue
                else:
                    hostgroup = workbook.sheets()[6].cell(n_1, 0).value
                    if hostgroup == '':
                        break
                    templateName = workbook.sheets()[6].cell(n_1, 1).value
                    if templateName == '':
                        break
                    try:
                        zabbix.host_massadd(hostgroup, templateName)
                    except Exception as e:
                        print u"Sheet3表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (n_1 + 1, e)
                        sys.exit(1)
        elif args.mrt:
            zabbix.host_massremove(args.mrt[0], args.mrt[1])
        elif args.mrte != 'mrte':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for n_1 in xrange(workbook.sheets()[6].nrows):
                if n_1 == 0:
                    continue
                else:
                    hostgroup = workbook.sheets()[6].cell(n_1, 0).value
                    if hostgroup == '':
                        break
                    templateName = workbook.sheets()[6].cell(n_1, 1).value
                    if templateName == '':
                        break
                    try:
                        zabbix.host_massremove(hostgroup, templateName)
                    except Exception as e:
                        print u"Sheet3表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (n_1 + 1, e)
                        sys.exit(1)
        #![08_创建主机组]
        elif args.cg:
            zabbix.hostGroup_create(args.cg[0])
        elif args.cge != 'cge':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[7].nrows):
                if row == 0:
                    continue
                else:                    
                    hostgroup = workbook.sheets()[7].cell(row, 0).value
                    if hostgroup == '':
                        break
                    try:
                        zabbix.hostGroup_create(hostgroup)
                    except Exception as e:
                        print u"Sheet1表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        elif args.dg:
            zabbix.hostGroup_delete(args.dg[0])
        elif args.dge != 'dge':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for row in xrange(workbook.sheets()[7].nrows):
                if row == 0:
                    continue
                else:
                    hostgroup = workbook.sheets()[7].cell(row, 0).value
                    if hostgroup == '':
                        break
                    try:
                        zabbix.hostGroup_delete(hostgroup)
                    except Exception as e:
                        print u"Sheet1表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (row + 1, e)
                        sys.exit(1)
        #![09_为主机附加主机组]
        elif args.mag:
            zabbix.hostGroup_massadd(args.mag[0], args.mag[1])
        elif args.mage != 'mage':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for n_1 in xrange(workbook.sheets()[8].nrows):
                if n_1 == 0:
                    continue
                else:
                    hostName = workbook.sheets()[8].cell(n_1, 0).value
                    if hostName == '':
                        break
                    hostGroupName = workbook.sheets()[8].cell(n_1, 1).value
                    if hostGroupName == '':
                        break
                    try:
                        zabbix.hostGroup_massadd(hostName, hostGroupName)
                    except Exception as e:
                        print u"Sheet3表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (n_1 + 1, e)
                        sys.exit(1)
        elif args.mrg:
            zabbix.hostGroup_massremove(args.mrt[0], args.mrt[1])
        elif args.mrge != 'mrge':
            workbook = xlrd.open_workbook('zabbix_api.xlsx')
            for n_1 in xrange(workbook.sheets()[8].nrows):
                if n_1 == 0:
                    continue
                else:
                    hostName = workbook.sheets()[8].cell(n_1, 0).value
                    if hostName == '':
                        break
                    hostGroupName = workbook.sheets()[8].cell(n_1, 1).value
                    if hostGroupName == '':
                        break
                    try:
                        zabbix.hostGroup_massremove(hostName, hostGroupName)
                    except Exception as e:
                        print u"Sheet3表第\033[041m%s\033[0m行数据异常\n\033[041m%s\033[0m" % (n_1 + 1, e)
                        sys.exit(1)
 


声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/盐析白兔/article/detail/424719
推荐阅读
相关标签
  

闽ICP备14008679号