update

celery_stats/es_status.py

@@ -29,7 +29,7 @@ data_dict = {}
 memory_used_rate_top = 0.8
 fs_free_rate_top = 0.8
 cpu_top = 75
-search_queue_max = 0
+search_queue_max = 1
 
 secret = 'SECbbfd6b7403869cf8a31e63e2d623378bd8a55b5a31083fad6421ee817794f485'
 access_token = '6eb687358606347cef617237cddab6a80e2f5981b46fe04950a96152e387f35c'
@@ -116,8 +116,8 @@ def parse_node_stats(data):
     old_gc_last = data_dict[node_name].get('old_gc',old_gc)
     old_gc_ms_last = data_dict[node_name].get('old_gc_ms',old_gc_ms)
 
-    queue_last = data_dict[node_name].get('queue',0)
-    rejected_last = data_dict[node_name].get('queue',0)
+    # queue_last = data_dict[node_name].get('queue',0)
+    rejected_last = data_dict[node_name].get('rejected',0)
 
     if search_thread_pool['queue'] > search_queue_max:
         res_str += '{}节点 search queue 目前为{} \n' .format(node_name,str(search_thread_pool['queue']))