|
|
@@ -85,7 +85,7 @@ def get_videos_remain_view_count(video_info_list):
|
|
|
if distribute_count > 0:
|
|
|
# 将分发数更新到本地记录
|
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
|
- redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=15 * 60)
|
|
|
+ redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=25 * 60)
|
|
|
else:
|
|
|
# 将本地记录删除
|
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
|
@@ -97,9 +97,6 @@ def get_videos_remain_view_count(video_info_list):
|
|
|
flow_pool_key = \
|
|
|
f"{config_.FLOWPOOL_KEY_NAME_PREFIX_SET_LEVEL_SUPPLY}{config_.APP_TYPE.get(type_name)}:{level}"
|
|
|
redis_helper.remove_value_from_set(key_name=flow_pool_key, values=(value, ))
|
|
|
- quick_flow_pool_key = f"{config_.QUICK_FLOWPOOL_KEY_NAME_PREFIX_SET}{config_.APP_TYPE.get(type_name)}" \
|
|
|
- f":{config_.QUICK_FLOW_POOL_ID}"
|
|
|
- redis_helper.remove_value_from_set(key_name=quick_flow_pool_key, values=(value, ))
|
|
|
bu_fen_fa_cnt = bu_fen_fa_cnt + 1
|
|
|
log_.info(f"新增加不分发过滤前后整体数量: {len(video_info_list)}:{str(bu_fen_fa_cnt)}")
|
|
|
|
supeng