处理路网异常捕获

tables.py

@@ -59,7 +59,6 @@ with open(json_file) as f:
 #
 # session_postgre.expire_on_commit = False
 
-
 # 创建对象的基类:
 Base = declarative_base()
 
@@ -69,48 +68,48 @@ sql_str = str("mysql+mysqlconnector://" + mysql_config["user"] + ":%s@" + mysql_
 postgre_str = str("postgresql://" + postgre_config["user"] + ":%s@" + postgre_config["host"] + \
                   ":" + postgre_config["port"] + "/" + postgre_config["database"])
 
-try:
-    engine_mysql = create_engine(
-        # "mysql+mysqlconnector://root:%s@192.168.28.111:3306/waytous"
-        # % quote("Huituo@123")
+# try:
+engine_mysql = create_engine(
+    # "mysql+mysqlconnector://root:%s@192.168.28.111:3306/waytous"
+    # % quote("Huituo@123")
 
-        # "mysql+mysqlconnector://" + mysql_config["user"] + ":" + mysql_config["password"] + "@" + mysql_config[
-        # "host"] + ":" + mysql_config["port"] + "/" + mysql_config["database"]
+    # "mysql+mysqlconnector://" + mysql_config["user"] + ":" + mysql_config["password"] + "@" + mysql_config[
+    # "host"] + ":" + mysql_config["port"] + "/" + mysql_config["database"]
 
-        sql_str % quote(mysql_config["password"])
-    )
+    sql_str % quote(mysql_config["password"])
+)
 
-    engine_postgre = create_engine(
-        # "postgresql://postgres:%s@192.168.28.111:5432/shenbao_2021520"
-        # % quote("Huituo@123")
+engine_postgre = create_engine(
+    # "postgresql://postgres:%s@192.168.28.111:5432/shenbao_2021520"
+    # % quote("Huituo@123")
 
-        # "postgresql://" + postgre_config["user"] + ":" + postgre_config["password"] + "@" + postgre_config[
-        #     "host"] + ":" + postgre_config["port"] + "/" + postgre_config["database"]
+    # "postgresql://" + postgre_config["user"] + ":" + postgre_config["password"] + "@" + postgre_config[
+    #     "host"] + ":" + postgre_config["port"] + "/" + postgre_config["database"]
 
-        postgre_str % quote(postgre_config["password"])
-    )
+    postgre_str % quote(postgre_config["password"])
+)
 
-    # 创建DBsession_mysql类型:
-    DBsession_mysql = sessionmaker(bind=engine_mysql)
+# 创建DBsession_mysql类型:
+DBsession_mysql = sessionmaker(bind=engine_mysql)
 
-    DBsession_mysql = scoped_session(DBsession_mysql)
+DBsession_mysql = scoped_session(DBsession_mysql)
 
-    DBsession_postgre = sessionmaker(bind=engine_postgre)
+DBsession_postgre = sessionmaker(bind=engine_postgre)
 
-    DBsession_postgre = scoped_session(DBsession_postgre)
+DBsession_postgre = scoped_session(DBsession_postgre)
 
-    # 创建session_mysql对象:
-    session_mysql = DBsession_mysql()
+# 创建session_mysql对象:
+session_mysql = DBsession_mysql()
 
-    session_mysql.expire_on_commit = False
+session_mysql.expire_on_commit = False
 
-    session_postgre = DBsession_postgre()
+session_postgre = DBsession_postgre()
 
-    session_postgre.expire_on_commit = False
-except Exception as es:
-    # logger.error("数据库连接失败")
-    # logger.error(es)
-    pass
+session_postgre.expire_on_commit = False
+# except Exception as es:
+#     # logger.error("数据库连接失败")
+#     # logger.error(es)
+#     pass
 
 
 # 定义对象: