update

celery_stats/celery_stats_monitor.py

@@ -28,11 +28,13 @@ class Parse_data:
         now = datetime.datetime.now()
         time_ts = now.strftime("%Y-%m-%d %H:%M:%S")
         if len_data <= self.top:
+            self.offset_dict[key_name] = len_data
             return None
         if self.offset_dict.get(key_name):
             old_len_data = self.offset_dict.get(key_name)
             len_data_diff = old_len_data - len_data
             rate = len_data_diff / per_sec
+            self.offset_dict[key_name] = len_data
             if len_data_diff > 0:
                 use_time = round(len_data/rate/(60/per_sec)/60,1)
                 return "{} 目前{}队列中有{}条数据,预计{}小时后处理完成".format(time_ts,key_name,str(len_data),str(use_time))