Merge branch 'feature_2023101311_liqian_add_abtest' into test

check_video_limit_distribute.py

@@ -31,7 +31,7 @@ def update_limit_video_score(initial_videos, key_name):
         if initial_score is not None:
             limit_video_initial_score.append((video_id, initial_score))
 
-    log_.info(f"limit_video_initial_score = {limit_video_initial_score}")
+    # log_.info(f"limit_video_initial_score = {limit_video_initial_score}")
 
     if len(limit_video_initial_score) == 0:
         return
@@ -62,8 +62,8 @@ def update_limit_video_score(initial_videos, key_name):
             final_score = media_score - limit_score_step * (i + 1)
             limit_video_final_score[int(video_id)] = final_score
 
-    log_.info(f"media_score = {media_score}, temp_score = {temp_score}, "
-              f"limit_video_final_score = {limit_video_final_score}")
+    # log_.info(f"media_score = {media_score}, temp_score = {temp_score}, "
+    #           f"limit_video_final_score = {limit_video_final_score}")
 
     # 更新限流视频的score
     if len(limit_video_final_score) == 0:

region_rule_rank_h.py

@@ -486,9 +486,9 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
     # 涉政视频过滤
     political_filter = param.get('political_filter', None)
     if political_filter is True:
-        log_.info(f"political filter videos count = {len(filtered_videos)}")
+        # log_.info(f"political filter videos count = {len(filtered_videos)}")
         filtered_videos = filter_political_videos(video_ids=filtered_videos)
-        log_.info(f"political filtered videos count = {len(filtered_videos)}")
+        # log_.info(f"political filtered videos count = {len(filtered_videos)}")
 
     # 写入对应的redis
     h_video_ids = []
@@ -496,10 +496,10 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
     if by_30day_rule_key is not None:
         # 与相对30天列表去重
         h_video_ids = get_day_30day_videos(now_date=now_date, data_key=data_key, rule_key=by_30day_rule_key)
-        log_.info(f"h_video_ids count = {len(h_video_ids)}")
+        # log_.info(f"h_video_ids count = {len(h_video_ids)}")
         if h_video_ids is not None:
             filtered_videos = [video_id for video_id in filtered_videos if int(video_id) not in h_video_ids]
-            log_.info(f"filtered_videos count = {len(filtered_videos)}")
+            # log_.info(f"filtered_videos count = {len(filtered_videos)}")
 
     h_recall_result = {}
     for video_id in filtered_videos:
@@ -511,7 +511,7 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key, rule_rank
         f"{config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H}{region}:{data_key}:{rule_key}:" \
         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)}")
+        # 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=2 * 24 * 3600)
         # 限流视频score调整
         update_limit_video_score(initial_videos=h_recall_result, key_name=h_recall_key_name)