update

region_rule_rank_h.py

@@ -217,7 +217,8 @@ def rank_by_h(project, table, now_date, now_h, rule_params, region_code_list):
             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({"region_code": region,
+            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']]})

rule_rank_day.py

@@ -162,7 +162,8 @@ def rank_by_day(now_date, rule_params, project, table):
         score_filename = f"score_{key}_{datetime.strftime(now_date, '%Y%m%d')}.csv"
         score_df.to_csv(f'./data/{score_filename}')
         # to-logs
-        log_.info({"redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_BY_DAY,
+        log_.info({"date": datetime.strftime(now_date, '%Y%m%d%H'),
+                   "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_BY_DAY,
                    "rule_key": key,
                    "score_df": score_df[['videoid', 'score']]})
 

rule_rank_h.py

@@ -207,7 +207,8 @@ def rank_by_h(now_date, now_h, rule_params):
         score_filename = f"score_{key}_{datetime.datetime.strftime(now_date, '%Y%m%d%H')}.csv"
         score_df.to_csv(f'./data/{score_filename}')
         # to-logs
-        log_.info({"redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_BY_H,
+        log_.info({"date": datetime.datetime.strftime(now_date, '%Y%m%d%H'),
+                   "redis_key_prefix": config_.RECALL_KEY_NAME_PREFIX_BY_H,
                    "rule_key": key,
                    "score_df": score_df[['videoid', 'score']]})