update

celery_stats/es_status.py

@@ -42,10 +42,10 @@ def get_cluster_stats(ip):
     timestamp = int(datetime.datetime.now().timestamp())
     memory_used = res_json["nodes"]['jvm']["mem"].get("heap_used_in_bytes")
     memory_total = res_json["nodes"]['jvm']["mem"].get("heap_max_in_bytes")
-    memory_used_rate = memory_used / memory_total
+    memory_used_rate = int(memory_used / memory_total)
     fs_available = res_json["nodes"]["fs"].get("available_in_bytes")
     fs_total = res_json["nodes"]["fs"].get("total_in_bytes")
-    fs_free_rate = fs_available / fs_total
+    fs_free_rate = int(fs_available / fs_total)
     return stats, timestamp, memory_used_rate, fs_free_rate
 
 
@@ -61,7 +61,8 @@ def get_node_status(ip):
     node_requests_res = requests.get(node_requests_url)
     res_json = node_requests_res.json()
 
-    for data in res_json["nodes"]:
+    for data_name in res_json["nodes"]:
+        data = res_json['nodes'][data_name]
         node_name = data['name']
         ip = data['ip']
         query_time = data["indices"]["search"]["query_time_in_millis"]