故障添加时间转化,删掉异常的时间

etl/wind_power/fault_warn/FaultWarnTrans.py

@@ -139,6 +139,7 @@ class FaultWarnTrans(BaseDataTrans):
         df = read_file_to_df(
             os.path.join(self.pathsAndTable.get_tmp_formal_path(), str(self.pathsAndTable.read_type) + '.csv'))
 
+        df['begin_time'] = pd.to_datetime(df['begin_time'], errors='coerce')
         self.engine_count = len(df['wind_turbine_number'].unique())
         self.min_date = df['begin_time'].min()
         self.max_date = df['begin_time'].max()
@@ -161,7 +162,6 @@ class FaultWarnTrans(BaseDataTrans):
         # 根据开始时间进行排序
         df.sort_values(by=['wind_turbine_number', 'begin_time'], inplace=True)
 
-
         if self.save_zip:
             df.to_csv(save_path, compression='gzip', index=False, encoding='utf-8', date_format='%Y-%m-%d %H:%M:%S')
         else:

utils/file/trans_methods.py

@@ -76,7 +76,7 @@ def find_read_header(file_path, trans_cols, resolve_col_prefix=None):
                 count = count + 1
                 if count > 2:
                     header = index + 1
-                    break
+                    return header
 
     return header