feat:添加分析任务

feature_spark_monitor.py

@@ -56,7 +56,6 @@ def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str):
         item for item in spark_task_list
         if table_name == item['name']
     ]
-    print(f"{table_name} ==> {filtered_data}")
     if filtered_data:
         latest_started_time = max(
             [date_util.str_cover_date(item['finishedTime']) for item in filtered_data])