import requests

 import json

 import sys

 def get_token():

     data = {

         "jsonrpc": "2.0",

         "method": "user.login",

         "params": {

             "user": username,

             "password": password

         },

         "id": 0

     }

     r = requests.get(zaurl, headers=header, data=json.dumps(data))

     auth = json.loads(r.text)

     return auth["result"]

 #指定模板，获取主机信息

 def template_hostget(token):

     data = {

                 "jsonrpc": "2.0",

                 "method": "template.get",

                 "params": {

                     "output": ['host', 'templateid'],

                     "templateids": [''],

                     "selectHosts": [   # 返回链接到模板的主机

                         "hostid",

                         "host",

                     ],

                 },

                 "auth": token,

                 "id": 1

             }

     request = requests.post(zaurl, data=json.dumps(data), headers=header)

     dict = json.loads(request.content)

     return (dict['result'][0]['hosts'])

 #获取连接的模板信息

 def hostget(token, hostid):

     data = {

                 "jsonrpc": "2.0",

                 "method": "host.get",

                 "params": {

                     "output": ["hostid","host"],

                     "selectParentTemplates": [

                         "templateid",

                         "name"

                     ],

                 "hostids": hostid

     },

                 "auth": token,

                 "id": 1

             }

     request = requests.post(zaurl, data=json.dumps(data), headers=header)

     dict = json.loads(request.content)

 #    print (dict)

     print (dict['result'][0]['hostid'],dict['result'][0]['host'],dict['result'][0]['parentTemplates'])

 def massupdate_templates_clear_hosts(token, hostid):

     data =  {

                 "jsonrpc": "2.0",

                 "method": "host.update",

                 "params": {

                     "hostid": hostid,

                     "templates_clear": ['']

                 },

                 "auth": token,

                 "id": 1

             }

     request = requests.post(zaurl, data=json.dumps(data), headers=header)

     print(request.content)

 def add_template(token, templateid, hostid):

     data = {

         "jsonrpc": "2.0",

         "method": "template.massadd",

         "params": {

             "templates": [

                 {

                     "templateid": templateid

                 },

             ],

             "hosts": [

                 {

                     "hostid": hostid

                 }

             ]

         },

         "auth": token,

         "id": 2

     }

     request = requests.post(zaurl, data=json.dumps(data), headers=header)

     print(request.content)

 if __name__ == "__main__":

 #修改输入参数

     hostfile = "主机IP.txt"

     zaurl = "http://x.x.x.x/zabbix/api_jsonrpc.php"

     header = {"Content-Type": "application/json"}

     username = "xx"

     password = "xx"

     token = get_token()

 #获取主机和模板

 #    hostinfo = template_hostget(token)

 #    for i in hostinfo:

 #       hostget(token, i['hostid'])

 #因监控机器数量太多，一次性全部修改会对zabbix数据库造成比较大的压力，所以分批修改

     hostids = [获取到主机在zabbix里面的hostid]

     for id in hostids:

 #    hostget(token,'15097')

         massupdate_templates_clear_hosts(token, id)

         add_template(token, "", id)