update

celery_stats/celery_stats_monitor.py

@@ -29,10 +29,10 @@ class Parse_data:
             rate = len_data_diff / per_sec
             if len_data_diff > 0:
                 use_time = round(len_data/rate/60/60,1)
-                return "目前队列中有{}条数据,预计{}小时后处理完成".format(str(len_data),str(use_time))
+                return "目前{}队列中有{}条数据,预计{}小时后处理完成".format(key_name,str(len_data),str(use_time))
             else:
                 if abs(rate) > 0:
-                    return "队列快速增长中"
+                    return "{}队列增长中,目前有{}条数据".format(key_name,str(len_data))
 
 
         self.offset_dict[key_name] = len_data