|
|
@@ -62,6 +62,7 @@ def predict_video_share_rate(video_initial_df, dt, data_key, data_param, top10_a
|
|
|
video_df = video_initial_df.copy()
|
|
|
video_df['apptype'] = video_df['apptype'].astype(int)
|
|
|
video_df = video_df[video_df['apptype'] == int(data_param)]
|
|
|
+ log_.info(f"video_df length: {len(video_df)}")
|
|
|
video_df['sharerate_all'].fillna(0, inplace=True)
|
|
|
video_df['sharerate_ad'].fillna(0, inplace=True)
|
|
|
video_df['sharerate_all'] = video_df['sharerate_all'].astype(float)
|
|
|
@@ -80,7 +81,9 @@ def predict_video_share_rate(video_initial_df, dt, data_key, data_param, top10_a
|
|
|
video_df['video_ad_share_rate'] = \
|
|
|
video_df['sharerate_ad'] * float(ad_all_videos_share_rate) / video_df['sharerate_all']
|
|
|
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]
|
|
|
+ log_.info(f"video_df filtered 0 length: {len(video_df)}")
|
|
|
# 结果写入redis
|
|
|
key_name = f"{config_.KEY_NAME_PREFIX_AD_VIDEO}{data_key}:{dt}"
|
|
|
redis_data = {}
|
