初始化添加异常拦截

etl/common/BaseDataTrans.py

@@ -27,8 +27,13 @@ class BaseDataTrans(object):
         self.batch_count = 100000
         self.save_db = save_db
         self.filed_conf = self.get_filed_conf()
-        self.pathsAndTable = PathsAndTable(self.batch_no, self.batch_name, self.read_path, self.field_name,
-                                           self.read_type, save_db, self.save_zip)
+        try:
+            self.pathsAndTable = PathsAndTable(self.batch_no, self.batch_name, self.read_path, self.field_name,
+                                               self.read_type, save_db, self.save_zip)
+        except Exception as e:
+            trans_print(traceback.format_exc())
+            update_trans_status_error(self.batch_no, self.read_type, str(e), self.save_db)
+            raise e
 
     def get_filed_conf(self):
         raise NotImplementedError("需要实现 获取点检表 方法")