|
@@ -166,8 +166,8 @@ def video_rank(df, now_date, now_h, rule_key, param, region):
|
|
log_.info(f'initial data count = {len(initial_data)}')
|
|
log_.info(f'initial data count = {len(initial_data)}')
|
|
|
|
|
|
# 获取符合进入召回源条件的视频,进入条件:小时级回流>=20 && score>=0.005
|
|
# 获取符合进入召回源条件的视频,进入条件:小时级回流>=20 && score>=0.005
|
|
- return_count = param.get('return_count')
|
|
|
|
- score_value = param.get('score_rule')
|
|
|
|
|
|
+ return_count = param.get('return_count', 1)
|
|
|
|
+ score_value = param.get('score_rule', 0)
|
|
h_recall_df = df[(df['lastonehour_return'] >= return_count) & (df['score'] >= score_value)]
|
|
h_recall_df = df[(df['lastonehour_return'] >= return_count) & (df['score'] >= score_value)]
|
|
h_recall_videos = h_recall_df['videoid'].to_list()
|
|
h_recall_videos = h_recall_df['videoid'].to_list()
|
|
log_.info(f'h_recall videos count = {len(h_recall_videos)}')
|
|
log_.info(f'h_recall videos count = {len(h_recall_videos)}')
|