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                 if vnfd_desc.get("vdu"):
  42                     for vdu in vnfd_desc['vdu']:
  43                         # Checks for vdu metric in vdu-configuration
  44                         if 'vdu-configuration' in vdu and 'metrics' in vdu['vdu-configuration']:
  45                             metric_list.extend([quote(metric['name'])
  46                                                for metric in vdu["vdu-configuration"]["metrics"]])
  47                 # Checks for vnf metric in vnf-configutaion
  48                 if 'vnf-configuration' in vnfd_desc and 'metrics' in vnfd_desc['vnf-configuration']:
  49                     metric_list.extend([quote(metric['name']) for metric in vnfd_desc["vnf-configuration"]["metrics"]])
  50         metric_list = list(set(metric_list))
  51         return metric_list
  52
  53     async def _prom_metric_request(self, ns_id, metrics_list):
  54         try:
  55             async with aiohttp.ClientSession() as session:
  56                 data = []
  57                 for metlist in metrics_list:
  58                     request_url = self.url+'/api/v1/query?query=osm_'+metlist+"{ns_id='"+ns_id+"'}"
  59                     async with session.get(request_url) as resp:
  60                         resp = await resp.json()
  61                         resp = resp['data']['result']
  62                         if resp:
  63                             data.append(resp)
  64                 return data
  65         except aiohttp.client_exceptions.ClientConnectorError as e:
  66             raise EngineException("Connection to '{}'Failure: {}".format(self.url, e))
  67
  68     def show(self, session, ns_id):
  69         metrics_list = self._get_vnf_metric_list(ns_id)
  70         loop = asyncio.new_event_loop()
  71         asyncio.set_event_loop(loop)
  72         prom_metric = loop.run_until_complete(self._prom_metric_request(ns_id, metrics_list))
  73         metric = {}
  74         metric_temp = []
  75         for index_list in prom_metric:
  76             for index in index_list:
  77                 process_metric = {'performanceValue': {'performanceValue': {}}}
  78                 process_metric['objectInstanceId'] = index['metric']['ns_id']
  79                 process_metric['performanceMetric'] = index['metric']['__name__']
  80                 process_metric['performanceValue']['timestamp'] = index['value'][0]
  81                 process_metric['performanceValue']['performanceValue']['performanceValue'] = index['value'][1]
  82                 process_metric['performanceValue']['performanceValue']['vnfMemberIndex'] \
  83                     = index['metric']['vnf_member_index']
  84                 if 'vdu_name' not in index['metric']:
  85                     pass
  86                 else:
  87                     process_metric['performanceValue']['performanceValue']['vduName'] = index['metric']['vdu_name']
  88                 metric_temp.append(process_metric)
  89         metric['entries'] = metric_temp
  90         return metric