|
@@ -154,6 +154,7 @@ def update_flow_pool(flow_pool_id_list):
|
|
|
quick_flow_pool_redis_data = set()
|
|
quick_flow_pool_redis_data = set()
|
|
|
# 普通流量池视频按照层级存储
|
|
# 普通流量池视频按照层级存储
|
|
|
flow_pool_redis_data = set()
|
|
flow_pool_redis_data = set()
|
|
|
|
|
+ video_info_list = []
|
|
|
|
|
|
|
|
for video_id in filtered_videos:
|
|
for video_id in filtered_videos:
|
|
|
for item in mapping.get(video_id):
|
|
for item in mapping.get(video_id):
|
|
@@ -175,7 +176,7 @@ def update_flow_pool(flow_pool_id_list):
|
|
|
# 1. 分发数量
|
|
# 1. 分发数量
|
|
|
# 更新剩余分发数
|
|
# 更新剩余分发数
|
|
|
log_.info(f"video_info_list count = {len(video_info_list)}")
|
|
log_.info(f"video_info_list count = {len(video_info_list)}")
|
|
|
- update_remain_view_count(video_info_list)
|
|
|
|
|
|
|
+ # update_remain_view_count(video_info_list)
|
|
|
|
|
|
|
|
|
|
|
|
|
# 2. quick曝光池
|
|
# 2. quick曝光池
|
|
@@ -225,7 +226,6 @@ def update_flow_pool(flow_pool_id_list):
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|
|
|
st_time = time.time()
|
|
st_time = time.time()
|
|
|
# 为避免第一个app_type获取数据不全，等待1min
|
|
# 为避免第一个app_type获取数据不全，等待1min
|
|
|
- time.sleep(60)
|
|
|
|
|
log_.info('flow pool predict start...')
|
|
log_.info('flow pool predict start...')
|
|
|
# 获取对应流量池id列表
|
|
# 获取对应流量池id列表
|
|
|
redis_helper = RedisHelper()
|
|
redis_helper = RedisHelper()
|
丁云鹏