flowpool

flowpool_data_update_with_level_score_v2.py

@@ -210,7 +210,7 @@ def update_flow_pool(flow_pool_id_list):
         # 3. 普通流量池
         for level, videos in flow_pool_redis_data.items():
             log_.info(f"level: {level}, videos_count: {len(videos)}")
-            flow_pool_key_name = f"flow:pool:level:item:score:v2:{app_type}{level}"
+            flow_pool_key_name = f"flow:pool:level:item:score:v2:{app_type}:{level}"
             # 如果key已存在，删除key
             if redis_helper.key_exists(flow_pool_key_name):
                 redis_helper.del_keys(flow_pool_key_name)