feat:修改监控脚本

script/feature_spark_monitor.py

@@ -91,19 +91,21 @@ def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str, st
     if time_difference > timedelta(minutes=120):
         return True, f"最近两个小时没有同步完成数据，最近一次完成时间为: {last_finished_item['finishedTime']}", "error"
 
-    # 判断持续时间是否超过一个小时
-    elapse = (finished_time - started_time)
-    print(f"表: {table_name}, 最后一次任务持续时间为: {date_util.seconds_convert(elapse.seconds)}")
+    finished_hour = finished_time.hour
+    if current_hour - finished_hour >= 2:
+        return True, f"最近两个小时没有同步完成数据，最近一次完成时间为: {last_finished_item['finishedTime']}", "error"
 
-    if elapse > timedelta(minutes=50):
-        return True, f"最近一次同步任务持续时间超过50分钟, 持续时间为: {date_util.seconds_convert(elapse.seconds)}", "warn"
+    # 判断持续时间是否超过一个小时
+    # elapse = (finished_time - started_time)
+    # print(f"表: {table_name}, 最后一次任务持续时间为: {date_util.seconds_convert(elapse.seconds)}")
+    # if elapse > timedelta(minutes=50):
+    #     return True, f"最近一次同步任务持续时间超过50分钟, 持续时间为: {date_util.seconds_convert(elapse.seconds)}", "warn"
 
     # 判断任务的完成时间是否是当前小时
-    finished_hour = finished_time.hour
-
-    print(f"表: {table_name}, 最后一次完成是: {finished_hour} 小时, 当前小时为: {current_hour}")
-    if finished_hour != current_hour:
-        return True, f"当前小时的任务未完成", "warn"
+    # finished_hour = finished_time.hour
+    # print(f"表: {table_name}, 最后一次完成是: {finished_hour} 小时, 当前小时为: {current_hour}")
+    # if finished_hour != current_hour:
+    #     return True, f"当前小时的任务未完成", "warn"
 
     return False, "", ""