|
|
@@ -291,14 +291,19 @@ def h_timer_check():
|
|
|
region_code_list = [code for region, code in region_code.items()]
|
|
|
now_date = datetime.datetime.today()
|
|
|
now_h = datetime.datetime.now().hour
|
|
|
+ now_min = datetime.datetime.now().minute
|
|
|
log_.info(f"now_date: {datetime.datetime.strftime(now_date, '%Y%m%d%H')}")
|
|
|
# 查看当天更新的数据是否已准备好
|
|
|
h_data_count = data_check(project=project, table=table, now_date=now_date)
|
|
|
if h_data_count > 0:
|
|
|
- log_.info(f'day_data_count = {h_data_count}')
|
|
|
+ log_.info(f'24h_data_count = {h_data_count}')
|
|
|
# 数据准备好，进行更新
|
|
|
rank_by_24h(now_date=now_date, now_h=now_h, rule_params=rule_params,
|
|
|
project=project, table=table, region_code_list=region_code_list)
|
|
|
+ elif now_min > 50:
|
|
|
+ log_.info('24h_recall data is None, use bottom data!')
|
|
|
+ for key, _ in rule_params.items():
|
|
|
+ h_rank_bottom(now_date=now_date, now_h=now_h, rule_key=key, region_code_list=region_code_list)
|
|
|
else:
|
|
|
# 数据没准备好，1分钟后重新检查
|
|
|
Timer(60, h_timer_check).start()
|
