Merge branch 'feature/zhangbo_flow_recall' of algorithm/rov-offline into master

flowpool_data_update_with_level.py

@@ -247,6 +247,12 @@ def get_flow_pool_data(app_type, video_info_list, flow_pool_id_list):
             # 写入redis
             if videos:
                 redis_helper.add_data_with_set(key_name=flow_pool_key_name, values=videos, expire_time=24 * 3600)
+                result = redis_helper.get_data_from_set(flow_pool_key_name)
+                if not result:
+                    result = []
+                size = len(result)
+                log_.info(f'写入成功key={flow_pool_key_name}:{size}')
+
 
         # 删除此时不存在的level key
         for i in range(1, 7):
@@ -255,6 +261,7 @@ def get_flow_pool_data(app_type, video_info_list, flow_pool_id_list):
                 # 如果key已存在，删除key
                 if redis_helper.key_exists(flow_pool_key_name):
                     redis_helper.del_keys(flow_pool_key_name)
+                    log_.info(f'删除不存在key={flow_pool_key_name}')
 
         log_.info('data to redis finished!')