蒙珣的博客

import json
import requests

class ZabbixAPI:
    def __init__(self, host, user, password) -> None:
        self.host = "http://" + host + "/zabbix/api_jsonrpc.php"
        self.user = user
        self.password = password

    def apiCall(self,data):
        headers = {"Content-Type": "application/json"}
        data = json.dumps(data)
        response = requests.post(self.host, data, headers=headers)
        responseResult = json.loads(response.text)
        return responseResult

    def login(self):
        data = {
            "jsonrpc": "2.0",
            "method": "user.login",
            "params": {
                "user": self.user,
                "password": self.password
            },
            "id": 0
        }
        response = self.apiCall(data)
        return response['result']

    def addZabbixHost(self,host,port):
        data = {
            "jsonrpc": "2.0",
            "method": "host.create",
            "params": {
                "host": host,
                "interfaces": [
                    {
                        "type": 1,
                        "main": 1,
                        "useip": 1,
                        "ip": host,
                        "dns": "",
                        "port": port
                    }
                ],
                "groups": [
                    {
                        "groupid": "4"
                    }
                ],
                "templates": [
                    {
                        "templateid": "10001"
                    }
                ]
            },
            "auth": self.login(),
            "id": 1
        }
        response = self.apiCall(data)
        if 'error' in response:
            print("ERROR：addZabbixHost()报错 " + response['error']['data'])
        else:
            print("添加监控主机成功：" + str(response['result']['hostids']))
            # 返回主机列表
            return response['result']['hostids']

    def getItems(self,host):
        data = {
            "jsonrpc": "2.0",
            "method": "item.get",
            "params": {
                "output": "extend",
                "host": host,  # 需要监控的主机
                "search": {
                    "key_": "system.cpu.util[,idle]"  # 监控项类型为"系统监控"
                }
            },
            "auth": self.login(),
            "id": 1,
        }
        response = self.apiCall(data)
        print(response)
        #return response["result"]

    # 检查已经添加的主机，并返回hostid列表
    def checkHost(self):
        data = {
            "jsonrpc": "2.0",
            "method": "host.get",
            "params": {
                "output": ["host"]
            },
            "auth": self.login(),
            "id": 1
        }
        response = self.apiCall(data)
        hostidList = []
        for i in response['result']:
            hostidList.append(i['hostid'])
            print("已经添加的主机有：" + str(i['hostid']))
        # 返回查询到的主机hostid列表    
        return hostidList

    # 导出配置
    def exportConf(self,hostidList=None):
        if hostidList is None:
            hostidList = self.checkHost()
        data = {
            "jsonrpc": "2.0",
            "method": "configuration.export",
            "params": {
                "options": {
                "hosts": hostidList
                },
            "format": "xml"
            },
            "auth": self.login(),
            "id": 1
        }
        response = self.apiCall(data)
        # 暂时不知道要干嘛，只是打印出来
        print(response)

p = ZabbixAPI('172.22.144.81', 'Admin', 'zabbix')
p.getItems('172.22.144.81')