update

celery_stats/es_status.py

@@ -26,8 +26,8 @@ import requests
 import datetime
 from meta_base_code.send_msg_to_dingding.send_msg import send_msg_to_dingtalk
 data_dict = {}
-memory_used_rate_top = 0.1
-fs_free_rate_top = 0.1
+memory_used_rate_top = 0.01
+fs_free_rate_top = 0.01
 cpu_top = 0.1
 
 secret = 'SECbbfd6b7403869cf8a31e63e2d623378bd8a55b5a31083fad6421ee817794f485'
@@ -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 = int(memory_used / memory_total)
+    memory_used_rate = round(memory_used / memory_total,4)
     fs_available = res_json["nodes"]["fs"].get("available_in_bytes")
     fs_total = res_json["nodes"]["fs"].get("total_in_bytes")
-    fs_free_rate = int(fs_available / fs_total)
+    fs_free_rate = round(fs_available / fs_total,4)
     return stats, timestamp, memory_used_rate, fs_free_rate