update FLOW_POOL_KEY_NAME

config.py

@@ -12,8 +12,8 @@ class BaseConfig(object):
     P = 0.5
     # ROV召回池redis key前缀，完整格式：com.weiqu.video.recall.hot.item.score.{date}
     RECALL_KEY_NAME_PREFIX = 'com.weiqu.video.recall.hot.item.score.'
-    # 流量池redis key
-    FLOW_POOL_KEY_NAME = 'com.weiqu.video.flowpool.hot.item.score'
+    # 流量池redis key前缀，完整格式 com.weiqu.video.flowpool.hot.item.score.{appType}
+    FLOW_POOL_KEY_NAME_PREFIX = 'com.weiqu.video.flowpool.hot.item.score.'
     # 首页推荐预曝光列表redis key 前缀，完整key格式：com.weiqu.video.hot.recommend.previewed.{appType}.{mid}
     PREVIEW_KEY_PREFIX = 'com.weiqu.video.hot.recommend.previewed.'
     # 用户上一次在rov召回池对应的位置 redis key前缀，完整key格式：com.weiqu.video.rov.pool.last.{appType}.{mid}.{date}

video_recall.py

@@ -78,7 +78,7 @@ class PoolRecall(object):
     def flow_pool_recall(self, size=10):
         """从流量池中获取视频"""
         log_.info('====== flow pool recall')
-        flow_pool_key = config_.FLOW_POOL_KEY_NAME
+        flow_pool_key = self.get_pool_redis_key('flow')
         flow_pool_recall_result = []
         flow_pool_recall_videos = []
         # 每次获取的视频数
@@ -142,6 +142,7 @@ class PoolRecall(object):
         :param flow_pool_mapping: 视频id-流量池标记mapping, type-dict
         :return:
         """
+        flow_pool_key = self.get_pool_redis_key('flow')
         videos = []
         for video_id in video_ids:
             for flow_pool in flow_pool_mapping[video_id]:
@@ -158,7 +159,7 @@ class PoolRecall(object):
                 # viewCount <= 0
                 # 从流量召回池移除
                 value = '{}-{}'.format(item[0], item[1])
-                self.redis_helper.remove_value_from_zset(key_name=config_.FLOW_POOL_KEY_NAME, value=value)
+                self.redis_helper.remove_value_from_zset(key_name=flow_pool_key, value=value)
         return check_result
 
     def get_pool_redis_key(self, pool_type):
@@ -180,7 +181,7 @@ class PoolRecall(object):
             return key_name, redis_date
 
         elif pool_type == 'flow':
-            return config_.FLOW_POOL_KEY_NAME
+            return config_.FLOW_POOL_KEY_NAME_PREFIX + str(self.app_type)
 
         else:
             log_.error('pool type error')