增加日志

alg_recsys_recall_1h_noregion.py

@@ -288,7 +288,7 @@ def h_timer_check():
             log_.info('上游数据表查询数据条数 h_data_count = {}，开始计算。'.format(h_data_count))
             # 数据准备好，进行更新
             rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params, project=project, table=table)
-            log_.info("----------正常完成----------")
+            log_.info("数据4----------正常完成----------")
         elif now_min > 40:
             log_.info('当前分钟超过40，预计执行无法完成，使用 bottom data!')
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params)

alg_recsys_recall_1h_region.py

@@ -45,7 +45,8 @@ RULE_PARAMS = {
         # 532
         # {'data': 'data66', 'rule': 'rule66'},  # 523-> 523 & 518
         {'data': 'data66', 'rule': 'rule67'},  # 523->510
-        {'data': 'data66', 'rule': 'rule68'},  # 523->514
+        # {'data': 'data66', 'rule': 'rule68'},  # 523->514
+        # {'data': 'data66', 'rule': 'rule69'},  # 523->518
     ],
 }
 
@@ -1132,7 +1133,7 @@ def h_timer_check():
             # 数据准备好，进行更新
             rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params,
                       project=project, table=table, region_code_list=region_code_list, rule_rank_h_flag=rule_rank_h_flag)
-            log_.info("----------正常完成----------")
+            log_.info("数据1----------正常完成----------")
         elif now_min > 40:
             log_.info('当前分钟超过40，预计执行无法完成，使用 bottom data!')
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params, region_code_list=region_code_list,

alg_recsys_recall_24h_noregion.py

@@ -414,7 +414,7 @@ def h_timer_check():
         elif h_data_count > 0:
             log_.info('上游数据表查询数据条数 h_data_count = {}，开始计算。'.format(h_data_count))
             rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params, project=project, table=table)
-            log_.info("----------正常完成----------")
+            log_.info("数据2----------正常完成----------")
         elif now_min > 40:
             log_.info('当前分钟超过40，预计执行无法完成，使用 bottom data!')
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params)

alg_recsys_recall_24h_region.py

@@ -429,7 +429,7 @@ def h_timer_check():
             log_.info('上游数据表查询数据条数 h_data_count = {}，开始计算。'.format(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)
-            log_.info("----------正常完成----------")
+            log_.info("数据3----------正常完成----------")
         elif now_min > 40:
             log_.info('当前分钟超过40，预计执行无法完成，使用 bottom data!')
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params, region_code_list=region_code_list)

alg_recsys_recall_aftermerge.py

@@ -45,7 +45,7 @@ RULE_PARAMS = {
         # 532
         # {'data': 'data66', 'rule': 'rule66'},  # 523-> 523 & 518
         {'data': 'data66', 'rule': 'rule67'},  # 523->510
-        {'data': 'data66', 'rule': 'rule68'},  # 523->514
+        # {'data': 'data66', 'rule': 'rule68'},  # 523->514
         # {'data': 'data66', 'rule': 'rule69'},  # 523->518
     ],
 }
@@ -406,7 +406,7 @@ def h_timer_check():
             # 数据准备好，进行更新
             rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params,
                       project=project, table=table, region_code_list=region_code_list, rule_rank_h_flag=rule_rank_h_flag)
-            log_.info("----------正常完成----------")
+            log_.info("合并5----------正常完成----------")
         else:
             log_.info('当前合并分钟超过45，预计执行无法完成，使用 bottom data!')
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params, region_code_list=region_code_list,