return 'Error stopping monitoring metric: {0} on {1}:{2}'.format(\r
metric, vnf_name, vnf_interface)\r
\r
-\r
-# get all metrics defined in the list and export it to Prometheus\r
-\r
def get_flow_metrics(self):\r
+ """\r
+ Get all metrics defined in the list and export it to Prometheus.\r
+ """\r
while self.start_monitoring:\r
\r
self.monitor_flow_lock.acquire()\r
'stats/flow', dpid=flow_dict['switch_dpid'], data=data)\r
if isinstance(ret, dict):\r
flow_stat_dict = ret\r
- elif isinstance(ret, basestring):\r
+ elif isinstance(ret, str):\r
flow_stat_dict = ast.literal_eval(ret.rstrip())\r
else:\r
flow_stat_dict = None\r
ret = self.net.ryu_REST('stats/port', dpid=dpid)\r
if isinstance(ret, dict):\r
port_stat_dict = ret\r
- elif isinstance(ret, basestring):\r
+ elif isinstance(ret, str):\r
port_stat_dict = ast.literal_eval(ret.rstrip())\r
else:\r
port_stat_dict = None\r