"disk_read_bytes": 1024,
"disk_write_bytes": 1024,
"packets_received": 1024,
- "packets_sent": 1024
+ "packets_sent": 1024,
}
-class vROPS_Helper():
-
- def __init__(self,
- vrops_site='https://vrops',
- vrops_user='',
- vrops_password=''):
+class vROPS_Helper:
+ def __init__(self, vrops_site="https://vrops", vrops_user="", vrops_password=""):
self.vrops_site = vrops_site
self.vrops_user = vrops_user
self.vrops_password = vrops_password
def get_vrops_token(self):
- """Fetches token from vrops
- """
- auth_url = '/suite-api/api/auth/token/acquire'
- headers = {'Content-Type': 'application/json', 'Accept': 'application/json'}
+ """Fetches token from vrops"""
+ auth_url = "/suite-api/api/auth/token/acquire"
+ headers = {"Content-Type": "application/json", "Accept": "application/json"}
req_body = {"username": self.vrops_user, "password": self.vrops_password}
- resp = requests.post(self.vrops_site + auth_url,
- json=req_body, verify=False,
- headers=headers)
+ resp = requests.post(
+ self.vrops_site + auth_url, json=req_body, verify=False, headers=headers
+ )
if resp.status_code != 200:
- log.error("Failed to get token from vROPS: {} {}".format(resp.status_code,
- resp.content))
+ log.error(
+ "Failed to get token from vROPS: {} {}".format(
+ resp.status_code, resp.content
+ )
+ )
return None
- resp_data = json.loads(resp.content.decode('utf-8'))
- return resp_data['token']
+ resp_data = json.loads(resp.content.decode("utf-8"))
+ return resp_data["token"]
def get_vm_resource_list_from_vrops(self):
- """ Find all known resource IDs in vROPs
- """
+ """Find all known resource IDs in vROPs"""
auth_token = self.get_vrops_token()
- api_url = '/suite-api/api/resources?resourceKind=VirtualMachine'
- headers = {'Accept': 'application/json', 'Authorization': 'vRealizeOpsToken {}'.format(auth_token)}
+ api_url = "/suite-api/api/resources?resourceKind=VirtualMachine"
+ headers = {
+ "Accept": "application/json",
+ "Authorization": "vRealizeOpsToken {}".format(auth_token),
+ }
resource_list = []
- resp = requests.get(self.vrops_site + api_url,
- verify=False, headers=headers)
+ resp = requests.get(self.vrops_site + api_url, verify=False, headers=headers)
if resp.status_code != 200:
- log.error("Failed to get resource list from vROPS: {} {}".format(resp.status_code,
- resp.content))
+ log.error(
+ "Failed to get resource list from vROPS: {} {}".format(
+ resp.status_code, resp.content
+ )
+ )
return resource_list
try:
- resp_data = json.loads(resp.content.decode('utf-8'))
- if resp_data.get('resourceList') is not None:
- resource_list = resp_data.get('resourceList')
+ resp_data = json.loads(resp.content.decode("utf-8"))
+ if resp_data.get("resourceList") is not None:
+ resource_list = resp_data.get("resourceList")
except Exception as exp:
- log.error("get_vm_resource_id: Error in parsing {}\n{}".format(exp, traceback.format_exc()))
+ log.error(
+ "get_vm_resource_id: Error in parsing {}\n{}".format(
+ exp, traceback.format_exc()
+ )
+ )
return resource_list
- def get_metrics(self,
- vdu_mappings={},
- monitoring_params={},
- vnfr=None,
- tags={}):
+ def get_metrics(self, vdu_mappings={}, monitoring_params={}, vnfr=None, tags={}):
monitoring_keys = {}
# Collect the names of all the metrics we need to query
for metric_entry in monitoring_params:
- metric_name = metric_entry['performance-metric']
+ metric_name = metric_entry["performance-metric"]
if metric_name not in METRIC_MAPPINGS:
log.debug("Metric {} not supported, ignoring".format(metric_name))
continue
sanitized_vdu_mappings = copy.deepcopy(vdu_mappings)
for key in vdu_mappings.keys():
vdu = vdu_mappings[key]
- if 'vrops_id' not in vdu:
+ if "vrops_id" not in vdu:
log.info("Could not find vROPS id for vdu {}".format(vdu))
del sanitized_vdu_mappings[key]
continue
- resource_ids += "&resourceId={}".format(vdu['vrops_id'])
+ resource_ids += "&resourceId={}".format(vdu["vrops_id"])
vdu_mappings = sanitized_vdu_mappings
try:
# Now we can make a single call to vROPS to collect all relevant metrics for resources we need to monitor
- api_url = "/suite-api/api/resources/stats?IntervalType=MINUTES&IntervalCount=1"\
+ api_url = (
+ "/suite-api/api/resources/stats?IntervalType=MINUTES&IntervalCount=1"
"&rollUpType=MAX¤tOnly=true{}{}".format(stats_key, resource_ids)
+ )
auth_token = self.get_vrops_token()
- headers = {'Accept': 'application/json', 'Authorization': 'vRealizeOpsToken {}'.format(auth_token)}
+ headers = {
+ "Accept": "application/json",
+ "Authorization": "vRealizeOpsToken {}".format(auth_token),
+ }
- resp = requests.get(self.vrops_site + api_url,
- verify=False, headers=headers)
+ resp = requests.get(
+ self.vrops_site + api_url, verify=False, headers=headers
+ )
if resp.status_code != 200:
- log.error("Failed to get Metrics data from vROPS for {} {}".format(resp.status_code,
- resp.content))
+ log.error(
+ "Failed to get Metrics data from vROPS for {} {}".format(
+ resp.status_code, resp.content
+ )
+ )
return metrics
- m_data = json.loads(resp.content.decode('utf-8'))
- if 'values' not in m_data:
+ m_data = json.loads(resp.content.decode("utf-8"))
+ if "values" not in m_data:
return metrics
- statistics = m_data['values']
+ statistics = m_data["values"]
for vdu_stat in statistics:
- vrops_id = vdu_stat['resourceId']
+ vrops_id = vdu_stat["resourceId"]
vdu_name = None
for vdu in vdu_mappings.values():
- if vdu['vrops_id'] == vrops_id:
- vdu_name = vdu['name']
+ if vdu["vrops_id"] == vrops_id:
+ vdu_name = vdu["name"]
if vdu_name is None:
continue
- for item in vdu_stat['stat-list']['stat']:
- reported_metric = item['statKey']['key']
+ for item in vdu_stat["stat-list"]["stat"]:
+ reported_metric = item["statKey"]["key"]
if reported_metric not in METRIC_MAPPINGS.values():
continue
# Convert the vROPS metric name back to OSM key
- metric_name = list(METRIC_MAPPINGS.keys())[list(METRIC_MAPPINGS.values()).
- index(reported_metric)]
+ metric_name = list(METRIC_MAPPINGS.keys())[
+ list(METRIC_MAPPINGS.values()).index(reported_metric)
+ ]
if metric_name in monitoring_keys.keys():
- metric_value = item['data'][-1]
+ metric_value = item["data"][-1]
if metric_name in METRIC_MULTIPLIERS:
metric_value *= METRIC_MULTIPLIERS[metric_name]
- metric = VnfMetric(vnfr['nsr-id-ref'],
- vnfr['member-vnf-index-ref'],
- vdu_name,
- metric_name,
- metric_value,
- tags
- )
+ metric = VnfMetric(
+ vnfr["nsr-id-ref"],
+ vnfr["member-vnf-index-ref"],
+ vdu_name,
+ metric_name,
+ metric_value,
+ tags,
+ )
metrics.append(metric)
except Exception as exp:
- log.error("Exception while parsing metrics data from vROPS {}\n{}".format(exp, traceback.format_exc()))
+ log.error(
+ "Exception while parsing metrics data from vROPS {}\n{}".format(
+ exp, traceback.format_exc()
+ )
+ )
return metrics
projects / osm / MON.git / blobdiff