|
|
@@ -72,10 +72,12 @@ def video_recommend(mid, uid, size, app_type, algo_type):
|
|
|
if preview_video_ids:
|
|
|
redis_helper.add_data_with_set(key_name=preview_key_name, values=tuple(preview_video_ids), expire_time=30*60)
|
|
|
log_.info('preview redis update success!')
|
|
|
- # 将此次获取的ROV召回池末位视频id同步刷新到Redis中，方便下次快速定位到召回位置，过期时间为1天
|
|
|
+ # 将此次获取的ROV召回池config_.K末位视频id同步刷新到Redis中，方便下次快速定位到召回位置，过期时间为1天
|
|
|
rov_recall_video = [item['videoId'] for item in rank_result if item['pushFrom'] == 'recall_pool']
|
|
|
- if rov_recall_video:
|
|
|
+ if 0 < len(rov_recall_video) <= config_.K:
|
|
|
redis_helper.set_data_to_redis(key_name=last_rov_recall_key, value=rov_recall_video[-1])
|
|
|
- log_.info('last video redis update success!')
|
|
|
+ elif len(rov_recall_video) > config_.K:
|
|
|
+ redis_helper.set_data_to_redis(key_name=last_rov_recall_key, value=rov_recall_video[config_.K - 1])
|
|
|
+ log_.info('last video redis update success!')
|
|
|
|
|
|
return rank_result
|
