|
|
@@ -45,21 +45,16 @@ def update_bottom_videos():
|
|
|
for record in reader:
|
|
|
video_id = record['videoid']
|
|
|
videos[video_id] = record['play_count']
|
|
|
- print(videos)
|
|
|
|
|
|
redis_helper = RedisHelper()
|
|
|
redis_helper.add_data_with_zset(key_name=config_.BOTTOM_KEY_NAME, data=videos)
|
|
|
# 移除bottom key的过期时间，将其转换为永久状态
|
|
|
redis_helper.persist_key(key_name=config_.BOTTOM_KEY_NAME)
|
|
|
|
|
|
- log_.info('{} update bottom videos success!'.format(now_date))
|
|
|
+ log_.info('{} update bottom videos success!, video nums = {}'.format(now_date, len(videos)))
|
|
|
except Exception as e:
|
|
|
log_.error(traceback.format_exc())
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
update_bottom_videos()
|
|
|
- # 将日志上传到oss
|
|
|
- log_cmd = "ossutil cp -r -f {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME,
|
|
|
- config_.OSS_FOLDER_LOGS + 'bottom_videos/')
|
|
|
- os.system(log_cmd)
|
