|
|
@@ -280,14 +280,14 @@ def rank_by_h(project, table, now_date, now_h, rule_params, region_code_list):
|
|
|
score_df = cal_score(df=region_df)
|
|
|
video_rank(df=score_df, now_date=now_date, now_h=now_h, rule_key=key, param=value, region=region)
|
|
|
# to-csv
|
|
|
- # score_filename = f"score_{region}_{key}_{datetime.datetime.strftime(now_date, '%Y%m%d%H')}.csv"
|
|
|
- # score_df.to_csv(f'./data/{score_filename}')
|
|
|
+ score_filename = f"score_{region}_{key}_{datetime.datetime.strftime(now_date, '%Y%m%d%H')}.csv"
|
|
|
+ score_df.to_csv(f'./data/{score_filename}')
|
|
|
# to-logs
|
|
|
- # log_.info({"date": datetime.datetime.strftime(now_date, '%Y%m%d%H'),
|
|
|
- # "region_code": region,
|
|
|
- # "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
|
|
|
- # "rule_key": key,
|
|
|
- # "score_df": score_df[['videoid', 'score']]})
|
|
|
+ log_.info({"date": datetime.datetime.strftime(now_date, '%Y%m%d%H'),
|
|
|
+ "region_code": region,
|
|
|
+ "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H,
|
|
|
+ "rule_key": key,
|
|
|
+ "score_df": score_df[['videoid', 'score']]})
|
|
|
|
|
|
|
|
|
def h_rank_bottom(now_date, now_h, rule_key, region_code_list):
|
