|
@@ -479,7 +479,7 @@ def update_local_distribute_count(videos):
|
|
|
for item in videos:
|
|
for item in videos:
|
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
|
|
|
# 本地记录的分发数 - 1
|
|
# 本地记录的分发数 - 1
|
|
|
- redis_helper.decr_key(key_name=key_name, amount=1, expire_time=5 * 60)
|
|
|
|
|
|
|
+ redis_helper.decr_key(key_name=key_name, amount=1, expire_time=15 * 60)
|
|
|
|
|
|
|
|
# if redis_helper.key_exists(key_name=key_name):
|
|
# if redis_helper.key_exists(key_name=key_name):
|
|
|
# # 该视频本地有记录，本地记录的分发数 - 1
|
|
# # 该视频本地有记录，本地记录的分发数 - 1
|
