commit 274a6e9fa4268db2a87525a27bc574c46eaa80dc
author Benjamin Diaz <bdiaz@whitestack.com> Mon Nov 26 13:14:33 2018 -0300
committer Benjamin Diaz <bdiaz@whitestack.com> Tue Nov 27 11:12:56 2018 -0300
tree 74cccebc92d2b8a545ac391a3a012c8bc0488a04
parent 44ebeeb78ca62e3e86dc218723bc417a3c4bd698

Adds use of aiokafka in mon-server

Adds request timeout param for requests made to Prometheus
Adds use of response topics based on cor_id for alarm create/delete RPC

Change-Id: I5544d749d812e4e77ba913b543ccaa83542535d4
Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>

osm_mon/evaluator/evaluator.py

diff --git a/osm_mon/evaluator/evaluator.py b/osm_mon/evaluator/evaluator.py
index a672cb2..8f49a66 100644
--- a/osm_mon/evaluator/evaluator.py
+++ b/osm_mon/evaluator/evaluator.py
@@ -59,7 +59,7 @@
             OSM_METRIC_PREFIX + metric_name, nsr_id, vdur_name, vnf_member_index)
         request_url = cfg.OSMMON_PROMETHEUS_URL + "/api/v1/query?" + query_section
         log.info("Querying Prometheus: %s", request_url)
-        r = requests.get(request_url)
+        r = requests.get(request_url, timeout=cfg.OSMMON_REQUEST_TIMEOUT)
         if r.status_code == 200:
             json_response = r.json()
             if json_response['status'] == 'success':