retry for get stats from dc

balancer/stats.py

 import requests
 import requests
 import json
 import json
 import logging
 import logging
+import time
 
 
 logger = logging.getLogger(__name__)
 logger = logging.getLogger(__name__)
 
 
 PREFIX = "RBstat?"
 PREFIX = "RBstat?"
 MEM_ALLOCATED_TARGET = "target=circle.*.memory.allocated&format=json&time=-1min"
 MEM_ALLOCATED_TARGET = "target=circle.*.memory.allocated&format=json&time=-1min"
-MEM_USAGE_TARGET = "circle.*.memory.usage&format=json&time=-1min"
+MEM_USAGE_TARGET = "target=circle.*.memory.usage&format=json&time=-1min"
 VMCOUNT_TARGET = "target=circle.*.vmcount&format=json&time=-1min"
 VMCOUNT_TARGET = "target=circle.*.vmcount&format=json&time=-1min"
 CPU_PERCENT_TARGET = "target=circle.*.cpu.percent&format=json&time=-1min"
 CPU_PERCENT_TARGET = "target=circle.*.cpu.percent&format=json&time=-1min"
 
 
@@ -18,7 +19,7 @@ STAT_TARGETS = {
 }
 }
 
 
 
 
-def get_stat_from_dc(datacenter):
+def get_stat_from_dc(datacenter, retry = False):
     stat = {}
     stat = {}
     for key, target in STAT_TARGETS.items():
     for key, target in STAT_TARGETS.items():
         url: str = f"{datacenter}/{PREFIX}{target}"
         url: str = f"{datacenter}/{PREFIX}{target}"
@@ -35,4 +36,14 @@ def get_stat_from_dc(datacenter):
             data = json.loads(req.content)
             data = json.loads(req.content)
             stat[key] = [i["datapoints"][0][0] for i in data]
             stat[key] = [i["datapoints"][0][0] for i in data]
 
 
+            if retry and stat[key][0] is None:
+                time.sleep(1)
+                req = requests.request(
+                    method="GET",
+                    url=url,
+                    verify=False,
+                )
+                data = json.loads(req.content)
+                stat[key] = [i["datapoints"][0][0] for i in data]
+
     return stat
     return stat

sredis/sredis.py

@@ -62,7 +62,7 @@ def update_datacenter_stats():
     all_keys = r.hgetall("datacenters_hash")
     all_keys = r.hgetall("datacenters_hash")
     for dc in all_keys.values():
     for dc in all_keys.values():
         logger.info(f"Get stats from {dc}")
         logger.info(f"Get stats from {dc}")
-        get_stat_from_dc(dc)
+        get_stat_from_dc(dc, retry=True)
         # update_stats(stats)
         # update_stats(stats)