sync redis

flowpool_data_update_with_level_score_v2.py

@@ -218,7 +218,7 @@ def update_flow_pool(flow_pool_id_list):
             if videos:
                 redis_helper.add_data_with_zset(key_name=flow_pool_key_name, data=videos, expire_time=24 * 3600)
         weight=json.dumps(level_weight)
-        redis_helper.set_data_to_redis(key_name="flow:pool:level:score:weight:v2", value=json.dumps(weight), expire_time=24*3600)
+        redis_helper.set_data_to_redis(key_name="flow:pool:level:score:weight:v2", value=weight, expire_time=24*3600)
         log_.info(f'权重 {weight}')
 
 

flowpool_data_update_with_level_v2.py

@@ -223,7 +223,7 @@ def update_flow_pool(flow_pool_id_list):
 
         # 4. 写入权重
         weight=json.dumps(level_weight)
-        redis_helper.set_data_to_redis(key_name="flow:pool:level:weight:v2", value=json.dumps(weight), expire_time=24*3600)
+        redis_helper.set_data_to_redis(key_name="flow:pool:level:weight:v2", value=weight, expire_time=24*3600)
         log_.info(f'权重 {weight}')