feat:添加特征Spark任务告警

client/YarnClient.py

@@ -29,6 +29,7 @@ class YarnClient(object):
             query_str = f"{query_str}&startedTimeEnd={started_time_end}"
 
         url = f"http://{self.cluster_ip}:8088/ws/v1/cluster/apps?{query_str}"
+        print(f"请求的Yarn Restful API为: {url}")
         response = requests.get(url)
         res = json.loads(response.text)
         result = []

feature_spark_monitor.py

@@ -149,7 +149,6 @@ def _main():
     # 读取配置文件
     config = configparser.ConfigParser()
     config.read("config/config.ini")
-    print(config.get("feishu", 'model.webhook'))
 
     # 获取最近七小时的Spark任务
     hours_7_early = int((datetime.now() - timedelta(hours=7)).timestamp()) * 1000