update

celery_stats/es_status.py

@@ -40,8 +40,8 @@ def get_cluster_stats(ip):
     res_json = node_requests_res.json()
     stats = res_json.get("status")
     timestamp = int(datetime.datetime.now().timestamp())
-    memory_used = res_json["nodes"]["mem"].get("heap_used_in_bytes")
-    memory_total = res_json["nodes"]["mem"].get("heap_max_in_bytes")
+    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
     fs_available = res_json["nodes"]["fs"].get("available_in_bytes")
     fs_total = res_json["nodes"]["fs"].get("total_in_bytes")