最新告警

WorkApi/APP/LatestWarning/latestWarning_acknowledge_eventid.py

+# -*- coding: utf-8 -*-
+# 确认告警
+# 作者: 陈磊
+# 时间: 2019-12-10
+from WorkUtils.UtilsRequest import UtilsRequest
+from WorkUtils.UtilsLog import UtilsLog
+from WorkApi.ApiBase import ApiBase, GetBase
+
+
+class LatestWarningAcknowledgeEventid(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 = "/latestWarning/acknowledge/"
+        self._url = self._host + self._path
+        self._params = {}
+        self._json = {}
+        self._data = {}
+        self.response = ""
+
+        self.token = {}
+
+        self.eventid = None
+
+        self.api = UtilsRequest()
+
+    def get_response(self):
+        base = ApiBase()
+        base.dict_add_key(_key="token", value=self.token)
+        self._headers = base._json
+
+        self._url = self._url + str(self.eventid)
+        self.response = self.api.get(url=self._url, headers=self._headers)

WorkApi/APP/LatestWarning/latestWarning_get.py

+# -*- coding: utf-8 -*-
+# 查询最新告警列表
+# 作者: 陈磊
+# 时间: 2019-12-10
+from WorkUtils.UtilsRequest import UtilsRequest
+from WorkUtils.UtilsLog import UtilsLog
+from WorkApi.ApiBase import ApiBase, GetBase
+
+
+class LatestWarningGet(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 = "/latestWarning/get"
+        self._url = self._host + self._path
+        self._params = {}
+        self._json = {}
+        self._data = {}
+        self.response = ""
+
+        self.token = None
+        self.severity = None
+        self.manageLevel = None
+        self.acknowledged = None
+        self.dateFrom = None
+        self.dateTo = None
+        self.hostType = None
+        self.hostName = None
+        self.alarmRuleid = None
+        self.experienceid = None
+        self.businessid = None
+
+        self.api = UtilsRequest()
+
+    def get_response(self):
+        base = ApiBase()
+        base.dict_add_key(_key="token", value=self.token)
+        self._headers = base._json
+
+        base = ApiBase()
+        base.dict_add_key(_key="severity", value=self.severity)
+        base.dict_add_key(_key="manageLevel", value=self.manageLevel)
+        base.dict_add_key(_key="acknowledged", value=self.acknowledged)
+        base.dict_add_key(_key="dateFrom", value=self.dateFrom)
+        base.dict_add_key(_key="dateTo", value=self.dateTo)
+        base.dict_add_key(_key="hostType", value=self.hostType)
+        base.dict_add_key(_key="hostName", value=self.hostName)
+        base.dict_add_key(_key="alarmRuleid", value=self.alarmRuleid)
+        base.dict_add_key(_key="experienceid", value=self.experienceid)
+        base.dict_add_key(_key="businessid", value=self.businessid)
+        self._params = base._json
+        self.response = self.api.get(url=self._url, headers=self._headers, params=self._params)

WorkApi/APP/LatestWarning/latestWarning_ignore_eventid.py

+# -*- coding: utf-8 -*-
+# 忽略告警
+# 作者: 陈磊
+# 时间: 2019-12-10
+from WorkUtils.UtilsRequest import UtilsRequest
+from WorkUtils.UtilsLog import UtilsLog
+from WorkApi.ApiBase import ApiBase, GetBase
+
+
+class LatestWarningIgnoreEventid(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 = "/latestWarning/ignore/"
+        self._url = self._host + self._path
+        self._params = {}
+        self._json = {}
+        self._data = {}
+        self.response = ""
+
+        self.token = {}
+
+        self.eventid = None
+
+        self.api = UtilsRequest()
+
+    def get_response(self):
+        base = ApiBase()
+        base.dict_add_key(_key="token", value=self.token)
+        self._headers = base._json
+
+        self._url = self._url + str(self.eventid)
+        self.response = self.api.get(url=self._url, headers=self._headers)

WorkCase/__init__.py

@@ -7,26 +7,11 @@
 class CaseBase:
     def __init__(self):
 
-        self.environment = {
-            # "host": "http://10.0.0.12:7070",
-            "db_url": "172.16.2.153",
-            "db_port": 3306,
-            "db_user": "zmops",
-            "db_pw": "0VMoH%W7|h",
-            "db_base": "zabbix",
-            "host": "http://172.16.3.197:7070",
-            # "db_url": "172.16.2.155",
-            # "db_port": 3306,
-            # "db_user": "root",
-            # "db_pw": "123456",
-            # "db_base": "zabbix"
-        }
-
         self.app_environment = {
             # 阿蒙
-            # "host": "http://172.16.3.25:3334",
+            "host": "http://172.16.3.25:3334/api",
             # 东方
-            "host": "http://172.16.3.78:3334/api",
+            # "host": "http://172.16.3.78:3334/api",
             "db_url": "172.16.2.155",
             "db_port": 3306,
             "db_user": "root",
@@ -46,13 +31,20 @@ class CaseBase:
             # "db_base": "zabbix",
         }
 
-        self.app_environment_host = {
-            "host": "http://172.16.3.78:3334",
-            "db_url": "172.16.2.155",
-            "db_port": 3306,
-            "db_user": "root",
-            "db_pw": "123456",
+        self.environment_test = {
+            "host": "http://client.argus.zmops.cn/api",
+            "db_url": "47.110.118.218",
+            "db_port": 23306,
+            "db_user": "argus",
+            "db_pw": "Argus@2019",
             "db_base": "argus",
+
+            "host_zabbix": "http://api.argus.zmops.cn",
+            # "host_zabbix": "http://172.16.3.197:7070",
+            "db_url_zabbix": "172.16.2.153",
+            "db_port_zabbix": 3306,
+            "db_user_zabbix": "zmops",
+            "db_pw_zabbix": "0VMoH%W7|h",
             "db_base_zabbix": "zabbix"
         }
 
@@ -71,19 +63,7 @@ class CaseBase:
             "OFF": 1
         }
 
-        self.environment_test = {
-            "host": "http://client.argus.zmops.cn/api",
-            "db_url": "47.110.118.218",
-            "db_port": 23306,
-            "db_user": "argus",
-            "db_pw": "Argus@2019",
-            "db_base": "argus",
-
-            "host_zabbix": "http://api.argus.zmops.cn",
-            # "host_zabbix": "http://172.16.3.197:7070",
-            "db_url_zabbix": "172.16.2.153",
-            "db_port_zabbix": 3306,
-            "db_user_zabbix": "zmops",
-            "db_pw_zabbix": "0VMoH%W7|h",
-            "db_base_zabbix": "zabbix"
+        self.acknowledged = {
+            "ON": 1,
+            "OFF": 0
         }

WorkData/Argus/problem.py

@@ -51,9 +51,10 @@ class DataProblem(object):
 
         self.table = Problem
 
-    def select_all_from_allKeys(self, session, hostid=None, host_name=None, available=None, monitor_status=None):
+    def select_all_from_allKeys(self, session, eventid=None, hostid=None, host_name=None, available=None, monitor_status=None):
         """
         :param session: 指针
+        :param eventid:
         :param hostid:
         :param host_name:
         :param available:
@@ -63,6 +64,7 @@ class DataProblem(object):
         self.log.debug("查询数据库:")
         try:
             base = UtilsDataBase()
+            base.add_param(_key="eventid", value=eventid)
             base.add_param(_key="hostid", value=hostid)
             base.add_param(_key="host_name", value=host_name)
             base.add_param(_key="available", value=available)