ZABBIXAPI自动检查主机-创新互联

# -*- coding:utf-8 -*-

import json
import urllib2
from urllib2 import URLError
#import sys
#import xlrd

class ZabbixTools:
    def __init__(self):
        self.url = 'http://10.11.0.215/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": 'zabbix'
            },
            "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()
            self.authID = response['result']
            return self.authID

   # 获取主机
    def host_get(self):
        data = json.dumps({
            "jsonrpc": "2.0",
            "method": "host.get",
            "params": {
                "output": ["hostid", "host"],
                "selectInterfaces": ["interfaceid", "ip"]
            },
            "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()

            lens = len(response['result'])
            if lens > 0:
                return response['result']
            else:
                return ""

####################################################################################
# -*- coding: utf-8 -*-

import xlrd
import xlwt

#xlutils结合xlrd可以达到修改excel文件目的
from xlutils.copy import copy

from openpyxl import Workbook

from openpyxl import load_workbook

from openpyxl.writer.excel import ExcelWriter

'''
1.类的内部调用：self.<方法名>(参数列表)。

2.在类的外部调用：<实例名>.<方法名>(参数列表)。

注意：以上两种调用方法中，提供的参数列表中都不用包括self。
'''

class ExcelOperation(object):

    '''
    设置默认参数：rowsize  colsize ,创建对象时可以写、可不写默认参数
    '''
    def __init__(self, filename, rowsize=0, colsize=0):
        self.filename = filename
        self.rowsize = rowsize
        self.colsize = colsize

    def open_excel(self):
        return  xlrd.open_workbook(self.filename)


    '''
    table = data.sheets()[0]       #通过索引顺序获取
    table = data.sheet_by_index(0) #通过索引顺序获取
    table = data.sheet_by_name(u'Sheet1')#通过名称获取
    '''

    def read_excel(self):
        workbook = self.open_excel()
        sheet = workbook.sheet_by_index(0)

        nrows = sheet.nrows
        ncols = sheet.ncols

        data = []

        for loop in range(0,nrows):
            data.append(sheet.row_values(loop))
        return data




    def write_excel(self):
        wbk = xlwt.Workbook()
        sheet = wbk.add_sheet('sheet1')
        # 第0行第一列 写入内容
        sheet.write(0,1,'test ')
        wbk.save('test.xls')

    def read_write_excel(self):
        '''
                4.openpyxl可以对excel文件进行读写操作

        from openpyxl import Workbook

        from openpyxl import load_workbook

        from openpyxl.writer.excel import ExcelWriter
        workbook_ = load_workbook(u"新歌检索失败1477881109469.xlsx")
        sheetnames =workbook_.get_sheet_names() #获得表单名字
        print sheetnames
        sheet = workbook_.get_sheet_by_name(sheetnames[0])
        print sheet.cell(row=3,column=3).value
        sheet['A1'] = '47'
        workbook_.save(u"新歌检索失败1477881109469_new.xlsx")
        wb = Workbook()
        ws = wb.active
        ws['A1'] = 4
        wb.save("新歌检索失败.xlsx")
                :return:
        '''

        workbook_ = load_workbook(u'test.xlsx')
        sheetnames = workbook_.get_sheet_names()
        sheet = workbook_.get_sheet_by_name(sheetnames[0])
        print sheet.cell(row=3, column=3).value               




##################################################################################
# -*- coding: utf-8 -*-

from  testZabbixApi import  ZabbixTools
from pyExcel import  ExcelOperation


# 程序的入口
if __name__ == "__main__":
    #实例化excel对象
    tab = ExcelOperation('主机列表.xlsx')
    data = tab.read_excel()
    dirc = {'item{}'.format(i): x for i, x in enumerate(data)}
    #print  dirc['item45'][6]

    # 实例化ZabbixTools对象
    test = ZabbixTools()
    result = test.host_get()

    for key in dirc:
        flag = 'F'
        for i in range(len(result)):
            if dirc[key][6].strip()  ==  result[i]["interfaces"][0]["ip"]:
                flag = 'T'
        if flag == 'T':
            #print(dirc[key][6] + " zabbix")
            pass

        else:
            print(dirc[key][6] + "not add zabbix")

让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：申请域名、网页空间、营销软件、网站建设、金平网站维护、网站推广。

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

当前文章：ZABBIXAPI自动检查主机-创新互联
地址分享：https://www.cdcxhl.com/article10/ddegdo.html

成都网站建设公司_创新互联，为您提供网站改版、App开发、手机网站建设、域名注册、ChatGPT、网站建设

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联