update

recommend.py

@@ -445,21 +445,21 @@ def update_redis_data(result, app_type, mid, top_K, expire_time=24*3600):
                 redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_24h_dup3_video[-1],
                                                expire_time=expire_time)
 
-            # 将此次获取的 相对48h筛选数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
-            rov_recall_48h_dup2_video = [item['videoId'] for item in result[:top_K]
-                                         if item['pushFrom'] == config_.PUSH_FROM['rov_recall_48h']]
-            if len(rov_recall_48h_dup2_video) > 0:
-                last_video_key = f'{config_.LAST_VIDEO_FROM_REGION_DUP2_48H_PREFIX}{app_type}:{mid}'
-                redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_48h_dup2_video[-1],
-                                               expire_time=expire_time)
-
-            # 将此次获取的 相对48h筛选后剩余数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
-            rov_recall_48h_dup3_video = [item['videoId'] for item in result[:top_K]
-                                         if item['pushFrom'] == config_.PUSH_FROM['rov_recall_48h_dup']]
-            if len(rov_recall_48h_dup3_video) > 0:
-                last_video_key = f'{config_.LAST_VIDEO_FROM_REGION_DUP3_48H_PREFIX}{app_type}:{mid}'
-                redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_48h_dup3_video[-1],
-                                               expire_time=expire_time)
+            # # 将此次获取的 相对48h筛选数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
+            # rov_recall_48h_dup2_video = [item['videoId'] for item in result[:top_K]
+            #                              if item['pushFrom'] == config_.PUSH_FROM['rov_recall_48h']]
+            # if len(rov_recall_48h_dup2_video) > 0:
+            #     last_video_key = f'{config_.LAST_VIDEO_FROM_REGION_DUP2_48H_PREFIX}{app_type}:{mid}'
+            #     redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_48h_dup2_video[-1],
+            #                                    expire_time=expire_time)
+            #
+            # # 将此次获取的 相对48h筛选后剩余数据列表 中的视频id同步刷新到redis中，方便下次快速定位到召回位置
+            # rov_recall_48h_dup3_video = [item['videoId'] for item in result[:top_K]
+            #                              if item['pushFrom'] == config_.PUSH_FROM['rov_recall_48h_dup']]
+            # if len(rov_recall_48h_dup3_video) > 0:
+            #     last_video_key = f'{config_.LAST_VIDEO_FROM_REGION_DUP3_48H_PREFIX}{app_type}:{mid}'
+            #     redis_helper.set_data_to_redis(key_name=last_video_key, value=rov_recall_48h_dup3_video[-1],
+            #                                    expire_time=expire_time)
 
         # 将此次分发的流量池视频，对 本地分发数-1 进行记录
         if app_type not in [config_.APP_TYPE['LAO_HAO_KAN_VIDEO'], config_.APP_TYPE['ZUI_JING_QI']]: