add update_in_flowpool_count_switch

config.py

@@ -701,6 +701,12 @@ class BaseConfig(object):
     # 宗教视频列表更新结果存放 redis key 前缀，完整格式：'religion:videos:item:{date}'
     KEY_NAME_PREFIX_RELIGION_VIDEOS = 'religion:videos:item:'
 
+    # 召回池分发视频在流量池中存在，该视频是否进行本地分发数-1 开关，1-开/0-关
+    IN_FLOW_POOL_COUNT_SWITCH = {
+        'key_name': 'recall:videos:in:flow:pool:count:switch',
+        'value': 1
+    }
+
     # ##################################### 广告模型配置 #####################################
 
     # 广告模型数据

update_in_flowpool_count_switch.py

@@ -0,0 +1,21 @@
+from config import set_config
+from log import Log
+from db_helper import RedisHelper
+
+config_, env = set_config()
+log_ = Log()
+
+
+def update_switch():
+    """修改召回池分发视频在流量池中存在，该视频是否进行本地分发数-1 开关"""
+    key_name = config_.IN_FLOW_POOL_COUNT_SWITCH['key_name']
+    value = config_.IN_FLOW_POOL_COUNT_SWITCH['value']
+    redis_helper = RedisHelper()
+    redis_helper.set_data_to_redis(key_name=key_name, value=value)
+    # 移除过期时间，将其转换为永久状态
+    redis_helper.persist_key(key_name=key_name)
+    log_.info(f"update switch finished, key_name = {key_name}, value = {value}")
+
+
+if __name__ == '__main__':
+    update_switch()