osm_nbi/pmjobs_topics.py

   1 # -*- coding: utf-8 -*-
   2
   3 # Licensed under the Apache License, Version 2.0 (the "License");
   4 # you may not use this file except in compliance with the License.
   5 # You may obtain a copy of the License at
   6 #
   7 #    http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 # Unless required by applicable law or agreed to in writing, software
  10 # distributed under the License is distributed on an "AS IS" BASIS,
  11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  12 # implied.
  13 # See the License for the specific language governing permissions and
  14 # limitations under the License.
  15
  16 import asyncio
  17 import aiohttp
  18 from http import HTTPStatus
  19 from urllib.parse import quote
  20 from osm_nbi.base_topic import EngineException
  21
  22 __author__ = "Vijay R S <vijay.r@tataelxsi.co.in>"
  23
  24
  25 class PmJobsTopic():
  26     def __init__(self, db, host=None, port=None):
  27         self.db = db
  28         self.url = 'http://{}:{}'.format(host, port)
  29         self.nfvi_metric_list = ['cpu_utilization', 'average_memory_utilization', 'disk_read_ops',
  30                                  'disk_write_ops', 'disk_read_bytes', 'disk_write_bytes',
  31                                  'packets_dropped', 'packets_sent', 'packets_received']
  32
  33     def _get_vnf_metric_list(self, ns_id):
  34         metric_list = self.nfvi_metric_list.copy()
  35         vnfr_desc = self.db.get_list("vnfrs", {"nsr-id-ref": ns_id})
  36         if not vnfr_desc:
  37             raise EngineException("NS not found with id {}".format(ns_id), http_code=HTTPStatus.NOT_FOUND)
  38         else:
  39             for vnfr in vnfr_desc:
  40                 vnfd_desc = self.db.get_one("vnfds", {"_id": vnfr["vnfd-id"]}, fail_on_empty=True, fail_on_more=False)
  41                 try:
  42                     configs = vnfd_desc.get("df")[0]["lcm-operations-configuration"]["operate-vnf-op-config"]["day1-2"]
  43                 except Exception:
  44                     configs = []
  45
  46                 for config in configs:
  47                     if "metrics" in config:
  48                         metric_list.extend([quote(metric['name']) for metric in config["metrics"]])
  49         metric_list = list(set(metric_list))
  50         return metric_list
  51
  52     async def _prom_metric_request(self, ns_id, metrics_list):
  53         try:
  54             async with aiohttp.ClientSession() as session:
  55                 data = []
  56                 for metlist in metrics_list:
  57                     request_url = self.url+'/api/v1/query?query=osm_'+metlist+"{ns_id='"+ns_id+"'}"
  58                     async with session.get(request_url) as resp:
  59                         resp = await resp.json()
  60                         resp = resp['data']['result']
  61                         if resp:
  62                             data.append(resp)
  63                 return data
  64         except aiohttp.client_exceptions.ClientConnectorError as e:
  65             raise EngineException("Connection to '{}'Failure: {}".format(self.url, e))
  66
  67     def show(self, session, ns_id, api_req=False):
  68         metrics_list = self._get_vnf_metric_list(ns_id)
  69         loop = asyncio.new_event_loop()
  70         asyncio.set_event_loop(loop)
  71         prom_metric = loop.run_until_complete(self._prom_metric_request(ns_id, metrics_list))
  72         metric = {}
  73         metric_temp = []
  74         for index_list in prom_metric:
  75             for index in index_list:
  76                 process_metric = {'performanceValue': {'performanceValue': {}}}
  77                 process_metric['objectInstanceId'] = index['metric']['ns_id']
  78                 process_metric['performanceMetric'] = index['metric']['__name__']
  79                 process_metric['performanceValue']['timestamp'] = index['value'][0]
  80                 process_metric['performanceValue']['performanceValue']['performanceValue'] = index['value'][1]
  81                 process_metric['performanceValue']['performanceValue']['vnfMemberIndex'] \
  82                     = index['metric']['vnf_member_index']
  83                 if 'vdu_name' not in index['metric']:
  84                     pass
  85                 else:
  86                     process_metric['performanceValue']['performanceValue']['vduName'] = index['metric']['vdu_name']
  87                 metric_temp.append(process_metric)
  88         metric['entries'] = metric_temp
  89         return metric