新增过滤

parameter_update.py

@@ -1,4 +1,3 @@
-import sys
 from my_utils import parse_json_for_risk_rule
 from my_utils import parse_json_for_risk_videos
 from db_helper import RedisHelper
@@ -54,8 +53,8 @@ def param_update_expansion_factor() -> int:
     # 容灾
     if data < 5:
         data = 5
-    elif data > 15:
-        data = 5
+    elif data > 25:
+        data = 25
     return data
 
 def param_update_risk_filter_flag() -> bool:

utils.py

@@ -325,6 +325,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)
+
         # log_.info({
         #     'logTimestamp': int(time.time() * 1000),
         #     'pool_type': "zhangbo-filter-pool_type",

video_recall.py

@@ -2812,7 +2812,6 @@ class PoolRecall(object):
         # 每次获取的视频数
         # get_size = size * 5
         get_size = size * self.expansion_factor
-
         # 记录获取频次
         freq = 0
         while len(pool_recall_result) < size: