add video_recall

video_recall.py

@@ -2167,7 +2167,7 @@ class PoolRecall(object):
     def get_selected_recall(self, size=4, region_code=''):
         """召回池召回视频"""
         pool_key_prefix = config_.RECALL_KEY_NAME_PREFIX_DUP2_REGION_24H_H
-        recall_key = f"{pool_key_prefix}:{region_code}:{self.data_key}:{self.rule_key}"
+        recall_key = f"{pool_key_prefix}:{self.data_key}:{self.rule_key}"
         print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
         print(data)
@@ -2186,7 +2186,7 @@ class PoolRecall(object):
     def get_no_selected_recall(self, size=4, region_code=''):
         """未选择召回池召回视频"""
         pool_key_prefix = config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H
-        recall_key = f"{pool_key_prefix}:{region_code}:{self.data_key}:{self.rule_key}"
+        recall_key = f"{pool_key_prefix}:{self.data_key}:{self.rule_key}"
         print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
         print(data)
@@ -2204,8 +2204,8 @@ class PoolRecall(object):
 
     def get_fast_flow_pool_recall(self, size=4):
         """快速流量池召回视频"""
-        pool_key_prefix = config_.RECALL_KEY_NAME_PREFIX_DUP3_REGION_24H_H
-        recall_key = f"{pool_key_prefix}:{region_code}:{self.data_key}:{self.rule_key}"
+        recall_key = f"{config_.QUICK_FLOWPOOL_KEY_NAME_PREFIX}{self.app_type}:{config_.QUICK_FLOW_POOL_ID}"
+
         #recall_key = "recall:item:score:region:dup3:24h:" :{data_key}: {rule_key}
         print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
@@ -2224,7 +2224,7 @@ class PoolRecall(object):
 
     def get_flow_pool_recall(self, size=4):
         """流量池召回视频"""
-        recall_key = ""
+        recall_key = f"{config_.FLOWPOOL_KEY_NAME_PREFIX}{self.app_type}"
         print("recall_key:", recall_key)
         data = self.redis_helper.get_data_from_redis(key_name=recall_key)
         print(data)