simulation 0913

settings.py

@@ -28,8 +28,8 @@ import time
 log_path = "/usr/local/fleet-log/dispatch"
 
 # 创建日志目录
-# if not os.path.exists(log_path):
-#     os.mkdir(log_path)
+if not os.path.exists(log_path):
+    os.mkdir(log_path)
 
 # logging初始化工作
 logging.basicConfig()
@@ -39,8 +39,8 @@ logger.setLevel(logging.INFO)
 
 
 # timefilehandler = logging.handlers.TimedRotatingFileHandler(log_path + "/dispatch.log", when='M', interval=1, backupCount=60)
-# filehandler = logging.handlers.RotatingFileHandler(log_path + "/dispatch.log", maxBytes=3*1024*1024, backupCount=10)
-filehandler = logging.handlers.RotatingFileHandler("./Logs/dispatch.log", maxBytes=3 * 1024 * 1024, backupCount=10)
+filehandler = logging.handlers.RotatingFileHandler(log_path + "/dispatch.log", maxBytes=3*1024*1024, backupCount=10)
+# filehandler = logging.handlers.RotatingFileHandler("./Logs/dispatch.log", maxBytes=3 * 1024 * 1024, backupCount=10)
 # 设置后缀名称，跟strftime的格式一样
 filehandler.suffix = "%Y-%m-%d_%H-%M.log"
 

tables.py

@@ -14,37 +14,42 @@ from sqlalchemy import Column, create_engine
 from sqlalchemy import VARCHAR, DateTime, Float, Integer, BOOLEAN
 from sqlalchemy.orm import sessionmaker, scoped_session
 from sqlalchemy.ext.declarative import declarative_base
-# import numpy as np
-# from redis import StrictRedis, ConnectionPool
-# import redis
-# from datetime import datetime, timedelta
-# import copy
-# import json
-# import sched
-# import time
+from urllib.parse import quote
+from settings import *
 
-
-# 创建对象的基类:
 Base = declarative_base()
 
-# 初始化数据库连接:
-engine_mysql = create_engine('mysql+mysqlconnector://root:Huituo@123@192.168.28.111:3306/waytous')
+try:
+    engine_mysql = create_engine(
+        "mysql+mysqlconnector://root:%s@192.168.28.111:3306/waytous"
+        % quote("Huituo@123")
+    )
+
+    engine_postgre = create_engine(
+        "postgresql://postgres:%s@192.168.28.111:5432/shenbao_2021520"
+        % quote("Huituo@123")
+    )
+
+    # 创建DBsession_mysql类型:
+    DBsession_mysql = sessionmaker(bind=engine_mysql)
 
-engine_postgre = create_engine('postgresql://postgres:Huituo@123@192.168.28.111:5432/shenbao_2021520')
+    DBsession_mysql = scoped_session(DBsession_mysql)
 
-# 创建DBsession_mysql类型:
-DBsession_mysql = sessionmaker(bind=engine_mysql)
+    DBsession_postgre = sessionmaker(bind=engine_postgre)
 
-DBsession_mysql = scoped_session(DBsession_mysql)
+    DBsession_postgre = scoped_session(DBsession_postgre)
 
-DBsession_postgre = sessionmaker(bind=engine_postgre)
+    # 创建session_mysql对象:
+    session_mysql = DBsession_mysql()
 
-DBsession_postgre = scoped_session(DBsession_postgre)
+    session_mysql.expire_on_commit = False
 
-# 创建session_mysql对象:
-session_mysql = DBsession_mysql()
+    session_postgre = DBsession_postgre()
 
-session_postgre = DBsession_postgre()
+    session_postgre.expire_on_commit = False
+except Exception as es:
+    logger.error("数据库连接失败")
+    logger.error(es)
 
 
 # 定义对象: