Merge branch 'feature_2023103115_liqian_ad_abtest' into test

ad_video_data_update_with_new_strategy.py

@@ -85,7 +85,7 @@ def predict_video_share_rate_with_ad(video_initial_df, dt, data_key, data_param,
         video_df['adrate_share'] * video_df['sharerate'] / video_df['ad_rate']
     video_df['video_ad_share_rate'].fillna(0, inplace=True)
     # log_.info(f"video_df: {video_df}")
-    video_df = video_df[video_df['video_ad_share_rate'] != 0]
+    # video_df = video_df[video_df['video_ad_share_rate'] != 0]
     log_.info(f"video_df filtered 0 length: {len(video_df)}")
     # 结果写入redis
     key_name = f"{config_.KEY_NAME_PREFIX_VIDEO_WITH_AD}{data_key}:{dt}"
@@ -130,7 +130,7 @@ def predict_video_share_rate_no_ad(video_initial_df, dt, data_key, data_param, t
         video_df['no_adrate_share'] * video_df['sharerate'] / video_df['no_ad_rate']
     video_df['video_no_ad_share_rate'].fillna(0, inplace=True)
     # log_.info(f"video_df: {video_df}")
-    video_df = video_df[video_df['video_no_ad_share_rate'] != 0]
+    # video_df = video_df[video_df['video_no_ad_share_rate'] != 0]
     log_.info(f"video_df filtered 0 length: {len(video_df)}")
     # 结果写入redis
     key_name = f"{config_.KEY_NAME_PREFIX_VIDEO_NO_AD}{data_key}:{dt}"