trend召回

config.py

@@ -2015,6 +2015,7 @@ class DevelopmentConfig(BaseConfig):
     # 用户已观看视频过滤 & 视频审核条件过滤 & 是否进入老年人社区过滤 & 话题状态过滤 接口地址
     # 参数types: 1-已观看 2-视频状态 3-是否进入老年人社区过滤 4-话题状态
     VIDEO_FILTER_URL = 'http://videotest-internal.yishihui.com/longvideoapi/openapi/recommend/filterVideos'
+    # VIDEO_FILTER_URL = 'http://recommend-common-internal.piaoquantv.com/longvideoapi/openapi/recommend/filterVideos'
 
     # 获取视频在流量池中的剩余可分发数接口地址
     GET_REMAIN_VIEW_COUNT_URL = 'http://testapi-internal.piaoquantv.com/flowpool/video/remainViewCount'
@@ -2214,7 +2215,7 @@ class ProductionConfig(BaseConfig):
 def set_config():
     # 获取环境变量 ROV_SERVER_ENV
     env = os.environ.get('ROV_SERVER_ENV')
-    # env = 'dev'
+    env = 'dev'
     if env is None:
         # log_.error('ENV ERROR: is None!')
         return

recommend.py

@@ -670,7 +670,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     if ab_code == 60098:
         rov_pool_recall = []
         if len(recall_result_list) >= 2:
-            region_recall = []#recall_result_list[0]
+            region_recall = recall_result_list[0]
             return_video_reall = []
             sim_recall = []
             trend_recall = []
@@ -718,7 +718,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     # add_flow_pool_recall_log
     recall_result_list = copy.deepcopy(recall_result_list)
     flow_pool_recall_process = {}
-
+    # print("zb:" + str(rov_pool_recall))
     # ####### 排序
     start_rank = time.time()
     # log_.info('====== rank')

video_recall.py

@@ -3967,7 +3967,6 @@ class PoolRecall(object):
                                videos_with_risk=self.videos_with_risk
                                )
         region_code = self.get_region_code()
-        print("zb" + str(data_for_filter))
         t = [gevent.spawn(filter_.filter_videos_for_group, region_code, videos) for videos in data_for_filter]
         gevent.joinall(t)
         result_list = [i.get() for i in t if i.get() is not None and len(i.get()) > 0]