|
@@ -105,10 +105,10 @@ def update_local_distribute_count(videos):
|
|
key_name = '{}{}.{}'.format(config_.LOCAL_DISTRIBUTE_COUNT_PREFIX, item['videoId'], item['flowPool'])
|
|
key_name = '{}{}.{}'.format(config_.LOCAL_DISTRIBUTE_COUNT_PREFIX, item['videoId'], item['flowPool'])
|
|
if redis_helper.key_exists(key_name=key_name):
|
|
if redis_helper.key_exists(key_name=key_name):
|
|
# 该视频本地有记录,本地记录的分发数 - 1
|
|
# 该视频本地有记录,本地记录的分发数 - 1
|
|
- redis_helper.decr_key(key_name=key_name, amount=1, expire_time=10 * 60)
|
|
|
|
|
|
+ redis_helper.decr_key(key_name=key_name, amount=1, expire_time=5 * 60)
|
|
else:
|
|
else:
|
|
# 该视频本地无记录,接口获取的分发数 - 1
|
|
# 该视频本地无记录,接口获取的分发数 - 1
|
|
- redis_helper.incr_key(key_name=key_name, amount=int(item['distributeCount']) - 1, expire_time=10 * 60)
|
|
|
|
|
|
+ redis_helper.incr_key(key_name=key_name, amount=int(item['distributeCount']) - 1, expire_time=5 * 60)
|
|
|
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
log_.error(traceback.format_exc())
|
|
log_.error(traceback.format_exc())
|