|
@@ -123,22 +123,22 @@ def update_bottom_videos():
|
|
# key_name=config_.W_H_RATE_UP_1_VIDEO_LIST_KEY_NAME['bottom_last'])
|
|
# key_name=config_.W_H_RATE_UP_1_VIDEO_LIST_KEY_NAME['bottom_last'])
|
|
# log_.info('update video w_h_rate to redis finished!')
|
|
# log_.info('update video w_h_rate to redis finished!')
|
|
|
|
|
|
- # 获取今日兜底视频的json,并存入redis
|
|
|
|
- video_json_list = []
|
|
|
|
- for i in range(0, len(video_id_list)//10):
|
|
|
|
- video_json = get_video_info_json(video_ids=video_id_list[i*10:(i+1)*10])
|
|
|
|
- if video_json is not None:
|
|
|
|
- video_json_list.extend(video_json)
|
|
|
|
- if len(video_json_list) >= 1000:
|
|
|
|
- break
|
|
|
|
- # 写入redis,先删除key,再重新写入
|
|
|
|
- redis_helper.del_keys(config_.BOTTOM_JSON_KEY_NAME)
|
|
|
|
- redis_helper.add_data_with_set(key_name=config_.BOTTOM_JSON_KEY_NAME, values=video_json_list[:1000])
|
|
|
|
- # 移除过期时间,将其转换为永久状态
|
|
|
|
- redis_helper.persist_key(key_name=config_.BOTTOM_JSON_KEY_NAME)
|
|
|
|
-
|
|
|
|
- log_.info('{} update bottom videos info json success!, count = {}'.format(now_date,
|
|
|
|
- len(video_json_list[:1000])))
|
|
|
|
|
|
+ # # 获取今日兜底视频的json,并存入redis
|
|
|
|
+ # video_json_list = []
|
|
|
|
+ # for i in range(0, len(video_id_list)//10):
|
|
|
|
+ # video_json = get_video_info_json(video_ids=video_id_list[i*10:(i+1)*10])
|
|
|
|
+ # if video_json is not None:
|
|
|
|
+ # video_json_list.extend(video_json)
|
|
|
|
+ # if len(video_json_list) >= 1000:
|
|
|
|
+ # break
|
|
|
|
+ # # 写入redis,先删除key,再重新写入
|
|
|
|
+ # redis_helper.del_keys(config_.BOTTOM_JSON_KEY_NAME)
|
|
|
|
+ # redis_helper.add_data_with_set(key_name=config_.BOTTOM_JSON_KEY_NAME, values=video_json_list[:1000])
|
|
|
|
+ # # 移除过期时间,将其转换为永久状态
|
|
|
|
+ # redis_helper.persist_key(key_name=config_.BOTTOM_JSON_KEY_NAME)
|
|
|
|
+ #
|
|
|
|
+ # log_.info('{} update bottom videos info json success!, count = {}'.format(now_date,
|
|
|
|
+ # len(video_json_list[:1000])))
|
|
|
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
log_.error(traceback.format_exc())
|
|
log_.error(traceback.format_exc())
|