码迷,mamicode.com
首页 > 编程语言 > 详细

Python一键添加Zabbix监控脚本

时间:2016-07-13 23:27:10      阅读:371      评论:0      收藏:0      [点我收藏+]

标签:

   由于时间关系没有在脚本里把创建主机组和模板的功能,只是单单实现了添加主机的功能 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.51cto.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 


本文出自 “目标:印度” 博客,请务必保留此出处http://shunzi115.blog.51cto.com/5184443/1826176

Python一键添加Zabbix监控脚本

标签:

原文地址:http://shunzi115.blog.51cto.com/5184443/1826176

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!