|
|
@@ -72,6 +72,7 @@ def app_rank_op(now_date, now_h):
|
|
|
redis_helper = RedisHelper()
|
|
|
key_name = get_redis_key_date(now_date=now_date)
|
|
|
initial_data = redis_helper.get_data_zset_with_index(key_name=key_name, start=0, end=-1, with_scores=True)
|
|
|
+ log_.info(f'initial data count = {len(initial_data)}')
|
|
|
|
|
|
# 获取当前小时op更新的数据
|
|
|
# op_key_name = f"{config_.APP_OP_VIDEOS_KEY_NAME_PREFIX}{dt.strftime(now_date, '%Y%m%d')}.{now_h}"
|
|
|
@@ -80,6 +81,7 @@ def app_rank_op(now_date, now_h):
|
|
|
# 倒序排序
|
|
|
op_data.sort(key=lambda x: x['rank'], reverse=True)
|
|
|
op_video_ids = [int(item['videoid']) for item in op_data]
|
|
|
+ log_.info(f'op video count = {len(op_video_ids)}')
|
|
|
|
|
|
# 对op更新数据给定score
|
|
|
final_data = dict()
|
|
|
@@ -94,6 +96,7 @@ def app_rank_op(now_date, now_h):
|
|
|
# print(video_id, score)
|
|
|
# print(op_data)
|
|
|
# print(final_data)
|
|
|
+ log_.info(f'final data count = {len(final_data)}')
|
|
|
|
|
|
# 存入对应的redis
|
|
|
final_key_name = f"{config_.APP_FINAL_RECALL_KEY_NAME_PREFIX}{dt.strftime(now_date, '%Y%m%d')}.{now_h}"
|
|
|
@@ -127,7 +130,7 @@ def app_rank_bottom(now_date, now_h):
|
|
|
|
|
|
def app_timer_check():
|
|
|
now_date = dt.today()
|
|
|
- print(dt.strftime(now_date, '%Y%m%d%H'))
|
|
|
+ log_.info(f"now_date: {dt.strftime(now_date, '%Y%m%d')}")
|
|
|
now_h = dt.now().hour
|
|
|
now_min = dt.now().minute
|
|
|
# 查看当前小时op更新的数据是否已准备好
|
|
|
@@ -138,6 +141,7 @@ def app_timer_check():
|
|
|
# 数据准备好，进行更新
|
|
|
app_rank_op(now_date=now_date, now_h=now_h)
|
|
|
elif now_min > 50:
|
|
|
+ log_.info('op data is None, use bottom data!')
|
|
|
app_rank_bottom(now_date=now_date, now_h=now_h)
|
|
|
else:
|
|
|
# 数据没准备好，1分钟后重新检查
|
liqian