debug

rule_rank_h.py

@@ -133,8 +133,10 @@ def video_rank(df, now_date, now_h, return_count):
         if int(video_id) not in h_video_ids:
             initial_data_dup[int(video_id)] = score
     log_.info(f"initial data dup count = {len(initial_data_dup)}")
-    initial_key_name = f"{config_.RECALL_KEY_NAME_PREFIX_DUP_H}{return_count}.{datetime.datetime.strftime(now_date, '%Y%m%d')}.{now_h}"
-    redis_helper.add_data_with_zset(key_name=initial_key_name, data=initial_data_dup, expire_time=23 * 3600)
+    initial_key_name = \
+        f"{config_.RECALL_KEY_NAME_PREFIX_DUP_H}{return_count}.{datetime.datetime.strftime(now_date, '%Y%m%d')}.{now_h}"
+    if len(initial_data_dup) > 0:
+        redis_helper.add_data_with_zset(key_name=initial_key_name, data=initial_data_dup, expire_time=23 * 3600)
 
 
     # # 去重合并
@@ -197,9 +199,9 @@ def h_rank_bottom(now_date, now_h, return_count):
 
 def h_timer_check():
     return_count_list = [20, 50]
-    now_date = datetime.datetime.today() - datetime.timedelta(hours=5)
+    now_date = datetime.datetime.today()
     log_.info(f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d%H')}")
-    now_h = datetime.datetime.now().hour - 5
+    now_h = datetime.datetime.now().hour
     now_min = datetime.datetime.now().minute
     if now_h == 0:
         for cnt in return_count_list: