Commit 17933444 by sanshi

all

parent b302ff89
# -*- coding: utf-8 -*-
# 创建动作
# 作者: 陈磊
# 时间: 2019-10-31
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class ActionCreate(object):
def __init__(self, _host, esc_period=None, name=None, eventsource=None, def_shortdata=None, def_longdata=None):
"""
:param _host: 域名
:param esc_period:
:param name:
:param eventsource:
:param def_shortdata:
:param def_longdata:
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建动作")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/action/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.esc_period = esc_period
self.eventsource = eventsource
self.name = name
self.def_shortdata = def_shortdata
self.def_longdata = def_longdata
self.filter = {}
self.filter_conditions = []
self.operations = []
self.operations_opconditions = []
self.operations_opmessage_grp = []
self.operations_opmessage = []
self.operations_opcommand = []
self.recovery_operations = []
self.recovery_operations_opmessage = []
self.acknowledge_operations = []
self.acknowledge_operations_opmessage = []
self.api = UtilsRequest()
def filter_conditions_add(self, conditiontype=None, operator=None, value=None):
self.filter_conditions.append({
"conditiontype": conditiontype,
"operator": operator,
"value": value
})
def operations_opconditions_add(self, conditiontype=None, operator=None, value=None):
self.operations_opconditions.append({
"conditiontype": conditiontype,
"operator": operator,
"value": value
})
def operations_opmessage_grp_add(self, opcommand_grpid=None, operationid=None, groupid=None):
self.operations_opmessage_grp.append({
"opcommand_grpid": opcommand_grpid,
"operationid": operationid,
"groupid": groupid
})
def operations_opmessage_add(self, operationid=None, default_msg=None, mediatypeid=None, message=None, subject=None):
self.operations_opmessage.append({
"operationid": operationid,
"default_msg": default_msg,
"mediatypeid": mediatypeid,
"message": message,
"subject": subject
})
def get_response(self):
self._json = {
"esc_period": self.esc_period,
"eventsource": self.eventsource,
"name": self.name,
"def_shortdata": self.def_shortdata,
"def_longdata": self.def_longdata,
}
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询动作
# 作者: 陈磊
# 时间: 2019-11-01
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase, GetBase
class ActionGet(GetBase):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
super().__init__()
self.log = UtilsLog()
self.log.info("调用查询动作")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/action/get"
self._url = self._host + self._path
self._params = {}
self._json = {}
self._data = {}
self.response = ""
self.local_json = {}
self.actionids = None
self.groupids = None
self.hostids = None
self.triggerids = None
self.mediatypeids = None
self.usrgrpids = None
self.userids = None
self.scriptids = None
self.selectFilter = None
self.selectOperations = None
self.selectRecoveryOperations = None
self.selectAcknowledgeOperations = None
self.api = UtilsRequest()
def get_response(self):
self.get_base_json()
base = ApiBase()
base.dict_add_key(_key="actionids", value=self.actionids)
base.dict_add_key(_key="groupids", value=self.groupids)
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="triggerids", value=self.triggerids)
base.dict_add_key(_key="mediatypeids", value=self.mediatypeids)
base.dict_add_key(_key="usrgrpids", value=self.usrgrpids)
base.dict_add_key(_key="userids", value=self.userids)
base.dict_add_key(_key="scriptids", value=self.scriptids)
base.dict_add_key(_key="selectFilter", value=self.selectFilter)
base.dict_add_key(_key="selectOperations", value=self.selectOperations)
base.dict_add_key(_key="selectRecoveryOperations", value=self.selectRecoveryOperations)
base.dict_add_key(_key="selectAcknowledgeOperations", value=self.selectAcknowledgeOperations)
self.local_json = base._json
# self.log.debug(self.local_json)
# self.log.debug(self.base_json)
# 当前接口支持的参数与公共参数合并
add = ApiBase()
add.dict_add_dict(_dict_1=self.local_json, _dict_2=self.base_json)
self._json = add._json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询版本号
# 作者: 陈磊
# 时间: 2019-10-23
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class ApiInfoVersion(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用查询版本号")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/apiinfo/version"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.api = UtilsRequest()
def get_response(self):
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建应用
# 作者: 陈磊
# 时间: 2019-10-22
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class ApplicationCreate(object):
def __init__(self, _host, applicationid=None, hostid=None, name=None, flags=None, templateids=None):
"""
:param _host: 域名
:param applicationid: 应用ID
:param hostid : 主机组的ID
:param name: 应用名称
:param flags: 应用程序的来源
:param templateids: 父模板应用程序的ID
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建应用")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/application/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.applicationid = applicationid
self.hostid = hostid
self.name = name
self.flags = flags
self.templateids = templateids
self.api = UtilsRequest()
def get_response(self):
self._json = {
"applicationid": self.applicationid,
"hostid": self.hostid,
"name": self.name,
"flags": self.flags,
"templateids": self.templateids
}
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 删除应用
# 作者: 陈磊
# 时间: 2019-10-23
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class ApplicationDelete(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用删除应用")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/application/delete"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.applicationIds = []
self.api = UtilsRequest()
def applicationIds_add(self, applicationId):
"""
:param applicationId:
:return:
"""
self.applicationIds.append(applicationId)
def get_response(self):
self._json = self.applicationIds
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 更新应用
# 作者: 陈磊
# 时间: 2019-10-23
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class ApplicationUpdate(object):
def __init__(self, _host, applicationid=None, hostid=None, name=None, flags=None, templateids=None):
"""
:param _host: 域名
:param applicationid: 应用ID
:param hostid : 主机组的ID
:param name: 应用名称
:param flags: 应用程序的来源
:param templateids: 父模板应用程序的ID
:return:
"""
self.log = UtilsLog()
self.log.info("调用更新应用")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/application/update"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.applicationid = applicationid
self.hostid = hostid
self.name = name
self.flags = flags
self.templateids = templateids
self.api = UtilsRequest()
def get_response(self):
self._json = {
"applicationid": self.applicationid,
"hostid": self.hostid,
"name": self.name,
"flags": self.flags,
"templateids": self.templateids
}
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 确认事件
# 作者: 陈磊
# 时间: 2019-10-24
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class EventAcknowledge(object):
def __init__(self, _host, eventids=None, action=None, message=None, severity=None):
"""
:param _host: 域名
:param eventids: 应用ID
:param action : 主机组的ID
:param message: 应用名称
:param severity: 应用程序的来源
:return:
"""
self.log = UtilsLog()
self.log.info("调用确认事件")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/event/acknowledge"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.response = ""
self.eventids = eventids
self.action = action
self.message = message
self.severity = severity
self.api = UtilsRequest()
def get_response(self):
self._json = {
"eventids": self.eventids,
"action": self.action,
"message": self.message,
"severity": self.severity,
}
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询历史
# 作者: 陈磊
# 时间: 2019-11-01
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase, GetBase
class HistoryGet(GetBase):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
super().__init__()
self.log = UtilsLog()
self.log.info("调用查询历史")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/history/get"
self._url = self._host + self._path
self._params = {}
self._json = {}
self._data = {}
self.response = ""
self.local_json = {}
self.history = None
self.hostids = None
self.itemids = None
self.time_from = None
self.time_till = None
self.api = UtilsRequest()
def get_response(self):
self.get_base_json()
base = ApiBase()
base.dict_add_key(_key="history", value=self.history)
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="itemids", value=self.itemids)
base.dict_add_key(_key="time_from", value=self.time_from)
base.dict_add_key(_key="time_till", value=self.time_till)
self.local_json = base._json
# self.log.debug(self.local_json)
# self.log.debug(self.base_json)
# 当前接口支持的参数与公共参数合并
add = ApiBase()
add.dict_add_dict(_dict_1=self.local_json, _dict_2=self.base_json)
self._json = add._json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建主机
# 作者: 陈磊
# 时间: 2019-10-22
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostCreate(object):
def __init__(self, _host, host=None, description=None, groupids=None, interfaces=None, tags=None, templateids=None, macros=None,
inventory=None, status=None, tls_accept=None, tls_psk_identity=None, tls_psk=None):
"""
:param _host: 域名
:param host:
:param description:
:param groupids:
:param interfaces:
:param tags:
:param templateids:
:param macros:
:param inventory:
:param status:
:param tls_accept:
:param tls_psk_identity:
:param tls_psk:
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建主机")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/host/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.host = host
self.description = description
self.groupids = groupids
self.interfaces = interfaces
self.tags = tags
self.templateids = templateids
self.macros = macros
self.inventory = inventory
self.status = status
self.tls_accept = tls_accept
self.tls_psk_identity = tls_psk_identity
self.tls_psk = tls_psk
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="host", value=self.host)
base.dict_add_key(_key="description", value=self.description)
base.dict_add_key(_key="groupids", value=self.groupids)
base.dict_add_key(_key="interfaces", value=self.interfaces)
base.dict_add_key(_key="tags", value=self.tags)
base.dict_add_key(_key="templateids", value=self.templateids)
base.dict_add_key(_key="macros", value=self.macros)
base.dict_add_key(_key="inventory", value=self.inventory)
base.dict_add_key(_key="status", value=self.status)
base.dict_add_key(_key="tlsAccept", value=self.tls_accept)
base.dict_add_key(_key="tlsPskIdentity", value=self.tls_psk_identity)
base.dict_add_key(_key="tlsPsk", value=self.tls_psk)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建主机组
# 作者: 陈磊
# 时间: 2019-10-22
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupCreate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.name = None
self.groupid = None
self.flags = None
self.internal = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="name", value=self.name)
base.dict_add_key(_key="groupid", value=self.groupid)
base.dict_add_key(_key="flags", value=self.flags)
base.dict_add_key(_key="internal", value=self.internal)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 删除主机组
# 作者: 陈磊
# 时间: 2019-10-22
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupDelete(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用删除主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/delete"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.groupids = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="groupids", value=self.groupids)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询主机组
# 作者: 陈磊
# 时间: 2019-10-21
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase, GetBase
class HostGroupGet(GetBase):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
super().__init__()
self.log = UtilsLog()
self.log.info("调用查询主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/get"
self._url = self._host + self._path
self._params = {}
self._json = {}
self._data = {}
self.response = ""
self.local_json = {}
self.graphids = None
self.groupids = None
self.hostids = None
self.maintenanceids = None
self.monitored_hosts = None
self.real_hosts = None
self.templated_hosts = None
self.templateids = None
self.triggerids = None
self.with_applications = None
self.with_graphs = None
self.with_hosts_and_templates = None
self.with_httptests = None
self.with_items = None
self.with_monitored_httptests = None
self.with_monitored_items = None
self.with_monitored_triggers = None
self.with_simple_graph_items = None
self.with_triggers = None
self.selectDiscoveryRule = None
self.selectGroupDiscovery = None
self.selectHosts = None
self.selectTemplates = None
self.limitSelects = None
self.api = UtilsRequest()
def get_response(self):
self.get_base_json()
base = ApiBase()
base.dict_add_key(_key="graphids", value=self.graphids)
base.dict_add_key(_key="groupids", value=self.groupids)
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="maintenanceids", value=self.maintenanceids)
base.dict_add_key(_key="monitored_hosts", value=self.monitored_hosts)
base.dict_add_key(_key="real_hosts", value=self.real_hosts)
base.dict_add_key(_key="templated_hosts", value=self.templated_hosts)
base.dict_add_key(_key="templateids", value=self.templateids)
base.dict_add_key(_key="triggerids", value=self.triggerids)
base.dict_add_key(_key="with_applications", value=self.with_applications)
base.dict_add_key(_key="with_graphs", value=self.with_graphs)
base.dict_add_key(_key="with_hosts_and_templates", value=self.with_hosts_and_templates)
base.dict_add_key(_key="with_httptests", value=self.with_httptests)
base.dict_add_key(_key="with_items", value=self.with_items)
base.dict_add_key(_key="with_monitored_httptests", value=self.with_monitored_httptests)
base.dict_add_key(_key="with_monitored_items", value=self.with_monitored_items)
base.dict_add_key(_key="with_monitored_triggers", value=self.with_monitored_triggers)
base.dict_add_key(_key="with_simple_graph_items", value=self.with_simple_graph_items)
base.dict_add_key(_key="with_triggers", value=self.with_triggers)
base.dict_add_key(_key="selectDiscoveryRule", value=self.selectDiscoveryRule)
base.dict_add_key(_key="selectGroupDiscovery", value=self.selectGroupDiscovery)
base.dict_add_key(_key="selectHosts", value=self.selectHosts)
base.dict_add_key(_key="selectTemplates", value=self.selectTemplates)
base.dict_add_key(_key="limitSelects", value=self.limitSelects)
self.local_json = base._json
# self.log.debug(self.local_json)
# self.log.debug(self.base_json)
# 当前接口支持的参数与公共参数合并
add = ApiBase()
add.dict_add_dict(_dict_1=self.local_json, _dict_2=self.base_json)
self._json = add._json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量添加主机组
# 作者: 陈磊
# 时间: 2019-10-21
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupMassadd(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量添加主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/massadd"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.groups = None
self.hosts = None
self.templates = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="groups", value=self.groups)
base.dict_add_key(_key="hosts", value=self.hosts)
base.dict_add_key(_key="templates", value=self.templates)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量删除主机组
# 作者: 陈磊
# 时间: 2019-10-21
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupMassremove(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量删除主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/massremove"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.groups = None
self.hosts = None
self.templates = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="groups", value=self.groups)
base.dict_add_key(_key="hosts", value=self.hosts)
base.dict_add_key(_key="templates", value=self.templates)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量更新主机组
# 作者: 陈磊
# 时间: 2019-10-21
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupMassupdate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量更新主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/massupdate"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.groups = None
self.hosts = None
self.templates = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="groups", value=self.groups)
base.dict_add_key(_key="hosts", value=self.hosts)
base.dict_add_key(_key="templates", value=self.templates)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 更新主机组
# 作者: 陈磊
# 时间: 2019-10-23
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostGroupUpdate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用更新主机组")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostgroup/update"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.name = None
self.groupid = None
self.flags = None
self.internal = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="name", value=self.name)
base.dict_add_key(_key="groupid", value=self.groupid)
base.dict_add_key(_key="flags", value=self.flags)
base.dict_add_key(_key="internal", value=self.internal)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建主机接口
# 作者: 陈磊
# 时间: 2019-11-11
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase
class HostInterfaceCreate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.dns = None
self.hostid = None
self.ip = None
self.main = None
self.port = None
self.type = None
self.useip = None
self.bulk = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="dns", value=self.dns)
base.dict_add_key(_key="hostid", value=self.hostid)
base.dict_add_key(_key="ip", value=self.ip)
base.dict_add_key(_key="main", value=self.main)
base.dict_add_key(_key="port", value=self.port)
base.dict_add_key(_key="type", value=self.type)
base.dict_add_key(_key="useip", value=self.useip)
base.dict_add_key(_key="bulk", value=self.bulk)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 删除主机接口
# 作者: 陈磊
# 时间: 2019-11-11
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostInterfaceDelete(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用删除主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/delete"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.interfaceids = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="interfaceids", value=self.interfaceids)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询主机接口
# 作者: 陈磊
# 时间: 2019-11-11
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase, GetBase
class HostInterfaceGet(GetBase):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
super().__init__()
self.log = UtilsLog()
self.log.info("调用查询主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/get"
self._url = self._host + self._path
self._params = {}
self._json = {}
self._data = {}
self.response = ""
self.local_json = {}
self.hostids = None
self.interfaceids = None
self.itemids = None
self.triggerids = None
self.selectItems = None
self.selectHosts = None
self.limitSelects = None
self.api = UtilsRequest()
def get_response(self):
self.get_base_json()
base = ApiBase()
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="interfaceids", value=self.interfaceids)
base.dict_add_key(_key="itemids", value=self.itemids)
base.dict_add_key(_key="triggerids", value=self.triggerids)
base.dict_add_key(_key="selectItems", value=self.selectItems)
base.dict_add_key(_key="selectHosts", value=self.selectHosts)
base.dict_add_key(_key="limitSelects", value=self.limitSelects)
self.local_json = base._json
# self.log.debug(self.local_json)
# self.log.debug(self.base_json)
# 当前接口支持的参数与公共参数合并
add = ApiBase()
add.dict_add_dict(_dict_1=self.local_json, _dict_2=self.base_json)
self._json = add._json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量添加主机接口
# 作者: 陈磊
# 时间: 2019-11-11
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostInterfaceMassadd(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量添加主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/massadd"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hosts = None
self.interfaces = None
self.interfaces_dns = None
self.interfaces_ip = None
self.interfaces_main = None
self.interfaces_port = None
self.interfaces_type = None
self.interfaces_useip = None
self.interfaces_bulk = None
self.api = UtilsRequest()
def get_response(self):
if self.interfaces_ip is not None:
self.interfaces = []
for x, y in enumerate(self.interfaces_ip):
base = ApiBase()
base.dict_add_key(_key="dns", value=self.interfaces_dns, num=x)
base.dict_add_key(_key="ip", value=self.interfaces_ip, num=x)
base.dict_add_key(_key="main", value=self.interfaces_main, num=x)
base.dict_add_key(_key="port", value=self.interfaces_port, num=x)
base.dict_add_key(_key="type", value=self.interfaces_type, num=x)
base.dict_add_key(_key="useip", value=self.interfaces_useip, num=x)
base.dict_add_key(_key="bulk", value=self.interfaces_bulk, num=x)
self.interfaces.append(base._json)
base = ApiBase()
base.dict_add_key(_key="hosts", value=self.hosts)
base.dict_add_key(_key="interfaces", value=self.interfaces)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量删除主机接口
# 作者: 陈磊
# 时间: 2019-11-14
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostInterfaceMassremove(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量删除主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/massremove"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hostids = None
self.interfaces = None
self.interfaces_dns = None
self.interfaces_ip = None
self.interfaces_main = None
self.interfaces_port = None
self.interfaces_type = None
self.interfaces_useip = None
self.interfaces_bulk = None
self.api = UtilsRequest()
def get_response(self):
if self.interfaces_ip is not None:
self.interfaces = []
for x, y in enumerate(self.interfaces_ip):
base = ApiBase()
base.dict_add_key(_key="dns", value=self.interfaces_dns, num=x)
base.dict_add_key(_key="ip", value=self.interfaces_ip, num=x)
base.dict_add_key(_key="main", value=self.interfaces_main, num=x)
base.dict_add_key(_key="port", value=self.interfaces_port, num=x)
base.dict_add_key(_key="type", value=self.interfaces_type, num=x)
base.dict_add_key(_key="useip", value=self.interfaces_useip, num=x)
base.dict_add_key(_key="bulk", value=self.interfaces_bulk, num=x)
self.interfaces.append(base._json)
base = ApiBase()
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="interfaces", value=self.interfaces)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 批量更新主机接口
# 作者: 陈磊
# 时间: 2019-11-19
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostInterfaceReplace(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用批量更新主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/replace"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hostids = None
self.interfaces = None
self.interfaces_dns = None
self.interfaces_ip = None
self.interfaces_main = None
self.interfaces_port = None
self.interfaces_type = None
self.interfaces_useip = None
self.interfaces_bulk = None
self.api = UtilsRequest()
def get_response(self):
if self.interfaces_ip is not None:
self.interfaces = []
for x, y in enumerate(self.interfaces_ip):
base = ApiBase()
base.dict_add_key(_key="dns", value=self.interfaces_dns, num=x)
base.dict_add_key(_key="ip", value=self.interfaces_ip, num=x)
base.dict_add_key(_key="main", value=self.interfaces_main, num=x)
base.dict_add_key(_key="port", value=self.interfaces_port, num=x)
base.dict_add_key(_key="type", value=self.interfaces_type, num=x)
base.dict_add_key(_key="useip", value=self.interfaces_useip, num=x)
base.dict_add_key(_key="bulk", value=self.interfaces_bulk, num=x)
self.interfaces.append(base._json)
base = ApiBase()
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="interfaces", value=self.interfaces)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 更新主机接口
# 作者: 陈磊
# 时间: 2019-11-12
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase
class HostInterfaceUpdate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用更新主机接口")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostinterface/update"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.interfaceid = None
self.dns = None
self.hostid = None
self.ip = None
self.main = None
self.port = None
self.type = None
self.useip = None
self.bulk = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="interfaceid", value=self.interfaceid)
base.dict_add_key(_key="dns", value=self.dns)
base.dict_add_key(_key="hostid", value=self.hostid)
base.dict_add_key(_key="ip", value=self.ip)
base.dict_add_key(_key="main", value=self.main)
base.dict_add_key(_key="port", value=self.port)
base.dict_add_key(_key="type", value=self.type)
base.dict_add_key(_key="useip", value=self.useip)
base.dict_add_key(_key="bulk", value=self.bulk)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建主机原型
# 作者: 陈磊
# 时间: 2019-11-11
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase
class HostPrototypeCreate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建主机原型")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostprototype/create"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hostid = None
self.host = None
self.name = None
self.status = None
self.templateid = None
self.tls_connect = None
self.tls_accept = None
self.tls_issuer = None
self.tls_subject = None
self.tls_psk_identity = None
self.tls_psk = None
self.groupLinks = None
self.groupPrototypes = None
self.templateids = None
self.ruleid = None
self.groupLinks_groupid = None
self.groupPrototypes_name = None
self.api = UtilsRequest()
def get_response(self):
if self.groupLinks_groupid is not None:
self.groupLinks = []
for x, y in enumerate(self.groupLinks_groupid):
base = ApiBase()
base.dict_add_key(_key="groupid", value=self.groupLinks_groupid, num=x)
self.groupLinks.append(base._json)
else:
pass
if self.groupPrototypes_name is not None:
self.groupPrototypes = []
for x, y in enumerate(self.groupPrototypes_name):
base = ApiBase()
base.dict_add_key(_key="name", value=self.groupPrototypes_name, num=x)
self.groupPrototypes.append(base._json)
else:
pass
base = ApiBase()
base.dict_add_key(_key="hostid", value=self.hostid)
base.dict_add_key(_key="host", value=self.host)
base.dict_add_key(_key="name", value=self.name)
base.dict_add_key(_key="status", value=self.status)
base.dict_add_key(_key="templateids", value=self.templateids)
base.dict_add_key(_key="tls_connect", value=self.tls_connect)
base.dict_add_key(_key="tls_accept", value=self.tls_accept)
base.dict_add_key(_key="tls_issuer", value=self.tls_issuer)
base.dict_add_key(_key="tls_subject", value=self.tls_subject)
base.dict_add_key(_key="tls_psk_identity", value=self.tls_psk_identity)
base.dict_add_key(_key="ruleid", value=self.ruleid)
base.dict_add_key(_key="groupLinks", value=self.groupLinks)
base.dict_add_key(_key="groupPrototypes", value=self.groupPrototypes)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 删除主机原型
# 作者: 陈磊
# 时间: 2019-11-13
from WorkApi.ApiBase import ApiBase
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class HostPrototypeDelete(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用删除主机原型")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostprototype/delete"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hostids = None
self.api = UtilsRequest()
def get_response(self):
base = ApiBase()
base.dict_add_key(_key="hostids", value=self.hostids)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 查询主机原型
# 作者: 陈磊
# 时间: 2019-11-13
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase, GetBase
class HostPrototypeGet(GetBase):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
super().__init__()
self.log = UtilsLog()
self.log.info("调用查询主机原型")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostprototype/get"
self._url = self._host + self._path
self._params = {}
self._json = {}
self._data = {}
self.response = ""
self.local_json = {}
self.hostids = None
self.discoveryids = None
self.inherited = None
self.selectDiscoveryRule = None
self.selectGroupLinks = None
self.selectGroupPrototypes = None
self.selectInventory = None
self.selectParentHost = None
self.selectTemplates = None
self.api = UtilsRequest()
def get_response(self):
self.get_base_json()
base = ApiBase()
base.dict_add_key(_key="hostids", value=self.hostids)
base.dict_add_key(_key="discoveryids", value=self.discoveryids)
base.dict_add_key(_key="inherited", value=self.inherited)
base.dict_add_key(_key="selectDiscoveryRule", value=self.selectDiscoveryRule)
base.dict_add_key(_key="selectGroupLinks", value=self.selectGroupLinks)
base.dict_add_key(_key="selectGroupPrototypes", value=self.selectGroupPrototypes)
base.dict_add_key(_key="selectInventory", value=self.selectInventory)
base.dict_add_key(_key="selectParentHost", value=self.selectParentHost)
base.dict_add_key(_key="selectTemplates", value=self.selectTemplates)
self.local_json = base._json
# self.log.debug(self.local_json)
# self.log.debug(self.base_json)
# 当前接口支持的参数与公共参数合并
add = ApiBase()
add.dict_add_dict(_dict_1=self.local_json, _dict_2=self.base_json)
self._json = add._json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 更新主机原型
# 作者: 陈磊
# 时间: 2019-11-11
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
from WorkApi.ApiBase import ApiBase
class HostPrototypeUpdate(object):
def __init__(self, _host):
"""
:param _host: 域名
:return:
"""
self.log = UtilsLog()
self.log.info("调用更新主机原型")
self.log.info(self.__class__)
self._host = _host
self._headers = {}
self._path = "/hostprototype/update"
self._url = self._host + self._path
self._params = {}
self._json = {}
self.local_json = {}
self.response = ""
self.hostid = None
self.host = None
self.name = None
self.status = None
self.templateid = None
self.tls_connect = None
self.tls_accept = None
self.tls_issuer = None
self.tls_subject = None
self.tls_psk_identity = None
self.tls_psk = None
self.groupLinks = None
self.groupPrototypes = None
self.templateids = None
# self.ruleid = None
self.groupLinks_groupid = None
self.groupPrototypes_name = None
self.api = UtilsRequest()
def get_response(self):
if self.groupLinks_groupid is not None:
self.groupLinks = []
for x, y in enumerate(self.groupLinks_groupid):
base = ApiBase()
base.dict_add_key(_key="groupid", value=self.groupLinks_groupid, num=x)
self.groupLinks.append(base._json)
else:
pass
if self.groupPrototypes_name is not None:
self.groupPrototypes = []
for x, y in enumerate(self.groupPrototypes_name):
base = ApiBase()
base.dict_add_key(_key="name", value=self.groupPrototypes_name, num=x)
self.groupPrototypes.append(base._json)
else:
pass
base = ApiBase()
base.dict_add_key(_key="hostid", value=self.hostid)
base.dict_add_key(_key="host", value=self.host)
base.dict_add_key(_key="name", value=self.name)
base.dict_add_key(_key="status", value=self.status)
base.dict_add_key(_key="templateids", value=self.templateids)
base.dict_add_key(_key="tls_connect", value=self.tls_connect)
base.dict_add_key(_key="tls_accept", value=self.tls_accept)
base.dict_add_key(_key="tls_issuer", value=self.tls_issuer)
base.dict_add_key(_key="tls_subject", value=self.tls_subject)
base.dict_add_key(_key="tls_psk_identity", value=self.tls_psk_identity)
# base.dict_add_key(_key="ruleid", value=self.ruleid)
base.dict_add_key(_key="groupLinks", value=self.groupLinks)
base.dict_add_key(_key="groupPrototypes", value=self.groupPrototypes)
self.local_json = base._json
self._json = self.local_json
self.response = self.api.post(url=self._url, json=self._json)
# -*- coding: utf-8 -*-
# 创建图片
# 作者: 陈磊
# 时间: 2019-10-23
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class Create(object):
def __init__(self, host, name=None, imagetype=None, image=None):
"""
:param host: 域名
:param name: 图片名称
:param imagetype: 图片类型
:param image: 图片Base64字符串
:return:
"""
self.log = UtilsLog()
self.log.info("调用创建图片接口")
self.log.info(self.__class__)
self.host = host
self.headers = {}
self.path = "/image/create"
self.url = self.host + self.path
self.params = {}
self.json = {}
self.response = ""
self.name = name
self.imagetype = imagetype
self.image = image
self.api = UtilsRequest()
def get_response(self):
self.json = {
"name": self.name,
"imagetype": self.imagetype,
"image": self.image,
}
self.response = self.api.post(url=self.url, json=self.json)
# -*- coding: utf-8 -*-
# 更新图片
# 作者: 陈磊
# 时间: 2019-10-23
from WorkUtils.UtilsRequest import UtilsRequest
from WorkUtils.UtilsLog import UtilsLog
class Update(object):
def __init__(self, host, imageid=None, name=None, imagetype=None, image=None):
"""
:param host: 域名
:param imageid: 图片ID
:param name: 图片名称
:param imagetype: 图片类型
:param image: 图片Base64字符串
:return:
"""
self.log = UtilsLog()
self.log.info("调用更新图片接口")
self.log.info(self.__class__)
self.host = host
self.headers = {}
self.path = "/image/update"
self.url = self.host + self.path
self.params = {}
self.json = {}
self.response = ""
self.imageid = imageid
self.name = name
self.imagetype = imagetype
self.image = image
self.api = UtilsRequest()
def get_response(self):
self.json = {
"imageid": self.imageid,
"name": self.name,
"imagetype": self.imagetype,
"image": self.image,
}
self.response = self.api.post(url=self.url, json=self.json)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment