新增过滤

utils.py

@@ -324,7 +324,7 @@ class FilterVideos(object):
         """视频过滤"""
         # todo: 添加app和region的风险过滤。
         st_viewed = time.time()
-        # videos_filtered = self.filter_videos_with_risk_video(self.video_ids, self.app_type, region_code)
+        videos_filtered = self.filter_videos_with_risk_video(self.video_ids, self.app_type, region_code)
         # log_.info({
         #     'logTimestamp': int(time.time() * 1000),
         #     'pool_type': "zhangbo-filter-pool_type",
@@ -339,7 +339,7 @@ class FilterVideos(object):
         # })
         # 预曝光过滤
         st_pre = time.time()
-        filtered_pre_result = self.filter_video_previewed(self.video_ids)
+        filtered_pre_result = self.filter_video_previewed(videos_filtered)
         # print("filtered_pre:", (time.time()-st_pre)*1000)
         # et_pre = time.time()
         # log_.info({
@@ -717,7 +717,7 @@ class FilterVideos(object):
         """视频过滤"""
         # todo: 添加app和region的风险过滤。
         st_viewed = time.time()
-        # videos_filtered = self.filter_videos_with_risk_video(self.video_ids, self.app_type, region_code)
+        videos_filtered = self.filter_videos_with_risk_video(self.video_ids, self.app_type, region_code)
         # log_.info({
         #     'logTimestamp': int(time.time() * 1000),
         #     'pool_type': "zhangbo-filter-pool_type",
@@ -732,7 +732,7 @@ class FilterVideos(object):
         # })
         # 预曝光过滤
         st_pre = time.time()
-        filtered_pre_result = self.filter_video_previewed(self.video_ids)
+        filtered_pre_result = self.filter_video_previewed(videos_filtered)
         # print("filtered_pre:", (time.time()-st_pre)*1000)
         # et_pre = time.time()
         # log_.info({

video_recall.py

@@ -48,7 +48,7 @@ class PoolRecall(object):
         self.h_data_key = data_key
         self.h_rule_key = h_rule_key
 
-        # self.expansion_factor = param_update_expansion_factor()
+        self.expansion_factor = param_update_expansion_factor()
 
 
 
@@ -2810,8 +2810,8 @@ class PoolRecall(object):
         recall_data = []
         pool_recall_result = []
         # 每次获取的视频数
-        get_size = size * 5
-        # get_size = size * self.expansion_factor
+        # get_size = size * 5
+        get_size = size * self.expansion_factor
 
         # 记录获取频次
         freq = 0