update expire time: 23h -> 48h

check_video_limit_distribute.py

@@ -68,7 +68,7 @@ def update_limit_video_score(initial_videos, key_name):
     # 更新限流视频的score
     if len(limit_video_final_score) == 0:
         return
-    redis_helper.add_data_with_zset(key_name=key_name, data=limit_video_final_score, expire_time=23 * 3600)
+    redis_helper.add_data_with_zset(key_name=key_name, data=limit_video_final_score, expire_time=2 * 24 * 3600)
 
 
 def check_videos_distribute():

laohaokan_recommend_update.py

@@ -51,7 +51,7 @@ def merge_process(initial_key_name, new_key_name, now_videos, religion_video_id_
         score = 100 - i * step
         new_result[int(video_id)] = score
     # 写入新的key中
-    redis_helper.add_data_with_zset(key_name=new_key_name, data=new_result, expire_time=23 * 3600)
+    redis_helper.add_data_with_zset(key_name=new_key_name, data=new_result, expire_time=2 * 24 * 3600)
     return now_videos, religion_video_id_list
 
 

region_rule_rank_h.py

@@ -271,7 +271,7 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
         f"{datetime.datetime.strftime(now_date, '%Y%m%d')}:{now_h}"
     if len(h_recall_result) > 0:
         log_.info(f"h_recall_result count = {len(h_recall_result)}")
-        redis_helper.add_data_with_zset(key_name=h_recall_key_name, data=h_recall_result, expire_time=23 * 3600)
+        redis_helper.add_data_with_zset(key_name=h_recall_key_name, data=h_recall_result, expire_time=2 * 24 * 3600)
         # 限流视频score调整
         update_limit_video_score(initial_videos=h_recall_result, key_name=h_recall_key_name)
         # 清空线上过滤应用列表
@@ -303,7 +303,7 @@ def dup_data(h_video_ids, initial_key_name, dup_key_name, region):
                 h_video_ids.append(int(video_id))
 
         if len(dup_data) > 0:
-            redis_helper.add_data_with_zset(key_name=dup_key_name, data=dup_data, expire_time=23 * 3600)
+            redis_helper.add_data_with_zset(key_name=dup_key_name, data=dup_data, expire_time=2 * 24 * 3600)
             # 限流视频score调整
             update_limit_video_score(initial_videos=dup_data, key_name=dup_key_name)
     return h_video_ids
@@ -505,7 +505,7 @@ def copy_data_for_city(region, city_code, data_key, rule_key, now_date, now_h):
                 city_data[int(video_id)] = score
 
         if len(city_data) > 0:
-            redis_helper.add_data_with_zset(key_name=city_key, data=city_data, expire_time=23 * 3600)
+            redis_helper.add_data_with_zset(key_name=city_key, data=city_data, expire_time=2 * 24 * 3600)
 
     log_.info(f"city_code = {city_code} end!")
 
@@ -696,7 +696,7 @@ def h_rank_bottom(now_date, now_h, rule_params, region_code_list, rule_rank_h_fl
             final_key_name = \
                 f"{key_prefix}{region}:{data_key}:{rule_key}:{datetime.datetime.strftime(now_date, '%Y%m%d')}:{now_h}"
             if len(final_data) > 0:
-                redis_helper.add_data_with_zset(key_name=final_key_name, data=final_data, expire_time=23 * 3600)
+                redis_helper.add_data_with_zset(key_name=final_key_name, data=final_data, expire_time=2 * 24 * 3600)
             # 与其他召回视频池去重，存入对应的redis
             dup_to_redis(h_video_ids=h_video_ids, now_date=now_date, now_h=now_h, rule_key=rule_key,
                          region_24h_rule_key=region_24h_rule_key, region=region,