|
|
@@ -391,6 +391,14 @@ def update_redis_data(result, app_type, mid, last_rov_recall_key, top_K, expire_
|
|
|
expire_time=expire_time)
|
|
|
# log_.info('last video redis update success!')
|
|
|
|
|
|
+ # 将此次获取的 地域分组相对24h数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
|
|
|
+ rov_recall_24h_dup1_video = [item['videoId'] for item in result[:top_K]
|
|
|
+ if item['pushFrom'] == config_.PUSH_FROM['rov_recall_region_24h']]
|
|
|
+ if len(rov_recall_24h_dup1_video) > 0:
|
|
|
+ last_video_key = f'{config_.LAST_VIDEO_FROM_REGION_DUP1_24H_PREFIX}{app_type}.{mid}'
|
|
|
+ redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_24h_dup1_video[-1],
|
|
|
+ expire_time=expire_time)
|
|
|
+
|
|
|
# 将此次获取的 相对24h筛选数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
|
|
|
rov_recall_24h_dup2_video = [item['videoId'] for item in result[:top_K]
|
|
|
if item['pushFrom'] == config_.PUSH_FROM['rov_recall_24h']]
|
