Pārlūkot izejas kodu

feat:添加新的特征表监控

zhaohaipeng 4 mēneši atpakaļ
vecāks
revīzija
1ee538c15f
1 mainītis faili ar 4 papildinājumiem un 4 dzēšanām
  1. 4 4
      script/feature_spark_monitor.py

+ 4 - 4
script/feature_spark_monitor.py

@@ -155,10 +155,10 @@ def _main():
     print_config(args.config)
 
     # 读取配置文件
-    # config = configparser.ConfigParser()
-    # config.read(args.config)
-    # webhook_url = config.get("feishu", "model.webhook")
-    webhook_url = 'https://open.feishu.cn/open-apis/bot/v2/hook/540d4098-367a-4068-9a44-b8109652f07c'
+    config = configparser.ConfigParser()
+    config.read(args.config)
+    webhook_url = config.get("feishu", "model.webhook")
+    # webhook_url = 'https://open.feishu.cn/open-apis/bot/v2/hook/540d4098-367a-4068-9a44-b8109652f07c'
 
     # 获取最近4小时的Spark任务
     hours_7_early = int((datetime.now() - timedelta(hours=4)).timestamp()) * 1000