feat:添加分析任务

feature_spark_monitor.py

@@ -56,6 +56,7 @@ def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str):
         item for item in spark_task_list
         if table_name in item['name'] and date_util.str_cover_date(item['finishedTime']) > filter_date
     ]
+    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])