fix(measure): push networks loadbalancers metrics error (#185)

Author: jianxiaoguo

rootfs/api/management/commands/measure_loadbalancers.py

@@ -25,8 +25,9 @@ def _measure_loadbalancers(self, app_map, timestamp):
         stop = timestamp - (timestamp % 3600)
         start = stop - 3600
         loadbalancers = []
-        for metric, (_, value) in async_to_sync(monitor.query_loadbalancer(
-                app_map.keys(), start, stop)):
+        for item in async_to_sync(monitor.query_loadbalancer)(app_map.keys(), start, stop):  # noqa
+            metric = item["metric"]
+            _, value = item["value"]
             ip = metric["ip"]
             namespace = metric["namespace"]
             owner_id = app_map[namespace].owner_id

rootfs/api/management/commands/measure_networks.py

@@ -19,8 +19,9 @@ def _measure_networks(self, app_map, timestamp):
         stop = timestamp - (timestamp % 3600)
         start = stop - 3600
         networks = []
-        for metric, (_, value) in async_to_sync(monitor.query_network_receive_flow(
-                app_map.keys(), start, stop)):
+        for item in async_to_sync(monitor.query_network_receive_flow)(app_map.keys(), start, stop):  # noqa
+            metric = item["metric"]
+            _, value = item["value"]
             networks.append({
                 "app_id":  str(app_map[metric['namespace']].uuid),
                 "owner": app_map[metric['namespace']].owner_id,
@@ -33,8 +34,9 @@ def _measure_networks(self, app_map, timestamp):
                 },
                 "timestamp": start
             })
-        for metric, (_, value) in async_to_sync(monitor.query_network_transmit_flow(
-                app_map.keys(), start, stop)):
+        for item in async_to_sync(monitor.query_network_transmit_flow)(app_map.keys(), start, stop):  # noqa
+            metric = item["metric"]
+            _, value = item["value"]
             networks.append({
                 "app_id":  str(app_map[metric['namespace']].uuid),
                 "owner": app_map[metric['namespace']].owner_id,

rootfs/api/views.py

@@ -1356,4 +1356,3 @@ async def proxy(self, request, username, path):
         return JsonResponse(data, status=status)
 
     get = post = proxy
-