|
@@ -70,8 +70,11 @@ def get_videos_remain_view_count(video_info_list):
|
|
|
if distribute_count > 0:
|
|
if distribute_count > 0:
|
|
|
# 将分发数更新到本地记录
|
|
# 将分发数更新到本地记录
|
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
|
- redis_helper.setnx_key(key_name=key_name, value=distribute_count, expire_time=10 * 60)
|
|
|
|
|
|
|
+ redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=15 * 60)
|
|
|
else:
|
|
else:
|
|
|
|
|
+ # 将本地记录删除
|
|
|
|
|
+ key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
|
|
|
+ redis_helper.del_keys(key_name=key_name)
|
|
|
# 从流量召回池移除
|
|
# 从流量召回池移除
|
|
|
value = '{}-{}'.format(item['videoId'], item['flowPool'])
|
|
value = '{}-{}'.format(item['videoId'], item['flowPool'])
|
|
|
for type_name in config_.APP_TYPE:
|
|
for type_name in config_.APP_TYPE:
|
