debug

rule_rank_h.py

@@ -178,15 +178,17 @@ def h_rank_bottom(now_date, now_h, return_count):
     else:
         redis_dt = datetime.datetime.strftime(now_date, '%Y%m%d')
         redis_h = now_h - 1
-    key_name = f"{config_.RECALL_KEY_NAME_PREFIX_BY_H}{return_count}.{redis_dt}.{redis_h}"
-    initial_data = redis_helper.get_data_zset_with_index(key_name=key_name, start=0, end=-1, with_scores=True)
-    final_data = dict()
-    for video_id, score in initial_data:
-        final_data[video_id] = score
-    # 存入对应的redis
-    final_key_name = \
-        f"{config_.RECALL_KEY_NAME_PREFIX_BY_H}{return_count}.{datetime.datetime.strftime(now_date, '%Y%m%d')}.{now_h}"
-    redis_helper.add_data_with_zset(key_name=final_key_name, data=final_data, expire_time=24 * 3600)
+    key_prefix_list = [config_.RECALL_KEY_NAME_PREFIX_BY_H, config_.RECALL_KEY_NAME_PREFIX_DUP_H]
+    for i, key_prefix in enumerate(key_prefix_list):
+        key_name = f"{key_prefix}{return_count}.{redis_dt}.{redis_h}"
+        initial_data = redis_helper.get_data_zset_with_index(key_name=key_name, start=0, end=-1, with_scores=True)
+        final_data = dict()
+        for video_id, score in initial_data:
+            final_data[video_id] = score
+        # 存入对应的redis
+        final_key_name = \
+            f"{key_prefix}{return_count}.{datetime.datetime.strftime(now_date, '%Y%m%d')}.{now_h}"
+        redis_helper.add_data_with_zset(key_name=final_key_name, data=final_data, expire_time=24 * 3600)
     # 清空线上过滤应用列表
     redis_helper.del_keys(key_name=f"{config_.H_VIDEO_FILER}{return_count}")