update local distribute count

flowpool_data_update_with_level_supply.py

@@ -84,11 +84,11 @@ def get_videos_remain_view_count(video_info_list):
             distribute_count = int(item['distributeCount'])
             if distribute_count > 0:
                 # 将分发数更新到本地记录
-                key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
+                key_name = f"{config_.SUPPLY_LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
                 redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=25 * 60)
             else:
                 # 将本地记录删除
-                key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
+                key_name = f"{config_.SUPPLY_LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
                 redis_helper.del_keys(key_name=key_name)
                 # 从流量召回池移除
                 value = '{}-{}'.format(item['videoId'], item['flowPool'])

my_config.py

@@ -22,7 +22,7 @@ class BaseConfig(object):
     }
     # 供给质量评估 appType
     SUPPLY_APP_TYPE = {
-        'PIAO_QUAN_VIDEO_PLUS': 17  # 票圈视频+
+        'PIAO_QUAN_HAOKAN_VIDEO': 23
     }
     # 数据存放路径
     DATA_DIR_PATH = './data'
@@ -678,6 +678,7 @@ class BaseConfig(object):
     QUICK_FLOWPOOL_DISTRIBUTE_RATE_KEY_NAME_PREFIX = 'flow:pool:quick:distribute:rate:'
     # 本地记录视频的可分发数，控制分发，完整key格式：flow:pool:local:distribute:count:{videoId}:{flowPool}
     LOCAL_DISTRIBUTE_COUNT_PREFIX = 'flow:pool:local:distribute:count:'
+    SUPPLY_LOCAL_DISTRIBUTE_COUNT_PREFIX = 'flow:pool:supply:local:distribute:count:'
 
     # 流量池videoId redis key前缀，完整格式 flow:pool:video:ids:{appType}
     FLOWPOOL_VIDEO_ID_KEY_NAME_PREFIX = 'flow:pool:video:ids:'