Forráskód Böngészése

feat:添加特征Spark任务告警

zhaohaipeng 11 hónapja
szülő
commit
664ec78a13
1 módosított fájl, 2 hozzáadás és 2 törlés
  1. 2 2
      feature_spark_monitor.py

+ 2 - 2
feature_spark_monitor.py

@@ -134,7 +134,7 @@ def send_error_info(table_name: str, latest_started_time: str, webhook: str):
             "zh_cn": {
                 "title": {
                     "tag": "plain_text",
-                    "content": "【测试】大数据表同步延迟告警"
+                    "content": "【测试】特征同步延迟告警"
                 },
                 "subtitle": {
                     "tag": "plain_text",
@@ -150,7 +150,7 @@ def send_error_info(table_name: str, latest_started_time: str, webhook: str):
 def _main():
     # 读取配置文件
     config = configparser.ConfigParser()
-    config.read("config/config.ini")
+    config.read("./config/config.ini")
     webhook_url = config.get("feishu", "model.webhook")
 
     # 获取最近七小时的Spark任务