python 一键添加 zabbix 监控脚本

中国网络水泥

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

• #!/usr/bin/python
  
• #coding:utf-8
  
• 
  
• import json
  
• import urllib2
  
• from urllib2 import URLError
  
• import sys
  
• 
  
• class ZabbixTools:
  
•     def __init__(self):
  
•         self.url = 'http://lihuipeng.blog.运维网.com/zabbix/api_jsonrpc.php'
  
•         self.header = {"Content-Type":"application/json"}
  
•          
  
•          
  
•          
  
•     def user_login(self):
  
•         data = json.dumps({
  
•                            "jsonrpc": "2.0",
  
•                            "method": "user.login",
  
•                            "params": {
  
•                                       "user": "Admin",
  
•                                       "password": "lihuipeng"
  
•                                       },
  
•                            "id": 0
  
•                            })
  
•          
  
•         request = urllib2.Request(self.url, data)
  
•         for key in self.header:
  
•             request.add_header(key, self.header[key])
  
•      
  
•         try:
  
•             result = urllib2.urlopen(request)
  
•         except URLError as e:
  
•             print "Auth Failed, please Check your name and password:", e.code
  
•         else:
  
•             response = json.loads(result.read())
  
•             result.close()
  
•             #print response['result']
  
•             self.authID = response['result']
  
•             return self.authID
  
•          
  
•     def host_get(self):
  
•         data = json.dumps({
  
•                            "jsonrpc":"2.0",
  
•                            "method":"host.get",
  
•                            "params":{
  
•                                      "output":["hostid","name"],
  
•                                      "filter":{"host":""}
  
•                                      },
  
•                            "auth":self.user_login(),
  
•                            "id":1,
  
•                            })
  
•          
  
•         request = urllib2.Request(self.url, data)
  
•         for key in self.header:
  
•             request.add_header(key, self.header[key])
  
•             
  
•      
  
•         try:
  
•             result = urllib2.urlopen(request)
  
•         except URLError as e:
  
•             if hasattr(e, 'reason'):
  
•                 print 'We failed to reach a server.'
  
•                 print 'Reason: ', e.reason
  
•             elif hasattr(e, 'code'):
  
•                 print 'The server could not fulfill the request.'
  
•                 print 'Error code: ', e.code
  
•         else:
  
•             response = json.loads(result.read())
  
•             result.close()
  
•             print "Number Of Hosts: ", len(response['result'])
  
•             for host in response['result']:
  
•                 print "Host ID:",host['hostid'],"Host Name:",host['name']
  
•                  
  
•     def hostgroup_get(self, hostgroupName):
  
•         data = json.dumps({
  
•                            "jsonrpc":"2.0",
  
•                            "method":"hostgroup.get",
  
•                            "params":{
  
•                                      "output": "extend",
  
•                                      "filter": {
  
•                                                 "name": [
  
•                                                          hostgroupName,
  
•                                                          ]
  
•                                                 }
  
•                                      },
  
•                            "auth":self.user_login(),
  
•                            "id":1,
  
•                            })
  
•          
  
•         request = urllib2.Request(self.url, data)
  
•         for key in self.header:
  
•             request.add_header(key, self.header[key])
  
•               
  
•         try:
  
•             result = urllib2.urlopen(request)
  
•         except URLError as e:
  
•             print "Error as ", e
  
•         else:
  
•             response = json.loads(result.read())
  
•             result.close()
  
•             print "hostgroup : %s ------ id : %s" % (response['result'][0]['name'], response['result'][0]['groupid'])
  
•             self.hostgroupID = response['result'][0]['groupid']
  
•             return response['result'][0]['groupid']
  
•             
  
•     def template_get(self, templateName):
  
•         data = json.dumps({
  
•                            "jsonrpc":"2.0",
  
•                            "method": "template.get",
  
•                            "params": {
  
•                                       "output": "extend",
  
•                                       "filter": {
  
•                                                  "host": [
  
•                                                           templateName,
  
•                                                           ]
  
•                                                  }
  
•                                       },
  
•                            "auth":self.user_login(),
  
•                            "id":1,
  
•                            })
  
•          
  
•         request = urllib2.Request(self.url, data)
  
•         for key in self.header:
  
•             request.add_header(key, self.header[key])
  
•               
  
•         try:
  
•             result = urllib2.urlopen(request)
  
•         except URLError as e:
  
•             print "Error as ", e
  
•         else:
  
•             response = json.loads(result.read())
  
•             result.close()
  
•             print "template : %s ------ id : %s" % (response['result'][0]['name'], response['result'][0]['templateid'])
  
•             self.templateID = response['result'][0]['templateid']
  
•             return response['result'][0]['templateid']
  
•                  
  
•     def host_create(self, hostip, hostgroupName, templateName):
  
•         data = json.dumps({
  
•                            "jsonrpc":"2.0",
  
•                            "method":"host.create",
  
•                            "params":{
  
•                                      "host": hostip,
  
•                                      "interfaces": [
  
•                                                         {
  
•                                                             "type": 1,
  
•                                                             "main": 1,
  
•                                                             "useip": 1,
  
•                                                             "ip": hostip,
  
•                                                             "dns": "",
  
•                                                             "port": "10050"
  
•                                                         }
  
•                                                     ],
  
•                                     "groups": [
  
•                                                     {
  
•                                                         "groupid": self.hostgroup_get(hostgroupName)
  
•                                                     }
  
•                                                ],
  
•                                     "templates": [
  
•                                                     {
  
•                                                         "templateid": self.template_get(templateName)
  
•                                                     }
  
•                                                   ],
  
•                                      },
  
•                            "auth": self.user_login(),
  
•                            "id":1                  
  
•         })
  
•         request = urllib2.Request(self.url, data)
  
•         for key in self.header:
  
•             request.add_header(key, self.header[key])
  
•               
  
•         try:
  
•             result = urllib2.urlopen(request)
  
•         except URLError as e:
  
•             print "Error as ", e
  
•         else:
  
•             response = json.loads(result.read())
  
•             result.close()
  
•             print "host : %s ------ id : %s" % (hostip, response['result']['hostids'])
  
•             self.hostid = response['result']['hostids']
  
•             return response['result']['hostids']
  
•          
  
•                  
  
•                  
  
• if __name__ == "__main__":
  
•     if len(sys.argv) != 4:
  
•         print "Usage: %s ip hostgroupName templateName" % sys.argv[0]
  
•         sys.exit(1)
  
•          
  
•     test = ZabbixTools()
  
•     test.host_create(sys.argv[1], sys.argv[2], sys.argv[2])
  
•                  
  
•                  
  
•                  
  
•                  
  
•                  
  

　　user_login  是帐号密码验证
　　host_get    是列出监控机
　　hostgroup_get  是获取主机组的ID
　　template_get   是获取模板的ID
　　host_create    添加主机
　　运行方式：（前提是test-group这个主机组和test-template这个模板必须存在）
　　./zabbix_tools.py  192.168.3.100  test-group  test-template
　　参考文章：
　　https://www.zabbix.com/documentation/2.0/manual/appendix/api