|
@@ -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['adrate_share'] * video_df['sharerate'] / video_df['ad_rate']
|
|
video_df['video_ad_share_rate'].fillna(0, inplace=True)
|
|
video_df['video_ad_share_rate'].fillna(0, inplace=True)
|
|
# log_.info(f"video_df: {video_df}")
|
|
# 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)}")
|
|
log_.info(f"video_df filtered 0 length: {len(video_df)}")
|
|
# 结果写入redis
|
|
# 结果写入redis
|
|
key_name = f"{config_.KEY_NAME_PREFIX_VIDEO_WITH_AD}{data_key}:{dt}"
|
|
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['no_adrate_share'] * video_df['sharerate'] / video_df['no_ad_rate']
|
|
video_df['video_no_ad_share_rate'].fillna(0, inplace=True)
|
|
video_df['video_no_ad_share_rate'].fillna(0, inplace=True)
|
|
# log_.info(f"video_df: {video_df}")
|
|
# 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)}")
|
|
log_.info(f"video_df filtered 0 length: {len(video_df)}")
|
|
# 结果写入redis
|
|
# 结果写入redis
|
|
key_name = f"{config_.KEY_NAME_PREFIX_VIDEO_NO_AD}{data_key}:{dt}"
|
|
key_name = f"{config_.KEY_NAME_PREFIX_VIDEO_NO_AD}{data_key}:{dt}"
|