连接池配置

app/api/engine.py

@@ -22,7 +22,6 @@ CFG_FILEPATH = work_dir + '/app/config/config.yaml'
 
 config = yaml.load(open(CFG_FILEPATH, 'r'), Loader=yaml.FullLoader)
 
-
 tamp_user_engine = create_engine(
     'mysql+pymysql://{user}:{password}@{host}:{port}/{db}?charset={charset}'.format(
         db=config[env]['MySQL']['tamp_user_db'],
@@ -31,7 +30,11 @@ tamp_user_engine = create_engine(
         user=config[env]['MySQL']['user'],
         password=config[env]['MySQL']['password'],
         charset="utf8"
-    )
+    ),
+    max_overflow=0,  # 超过连接池大小外最多创建的连接
+    pool_size=100,  # 连接池大小
+    pool_timeout=30,  # 池中没有线程最多等待的时间，否则报错
+    pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收（重置）
 )
 tamp_pay_engine = create_engine(
     'mysql+pymysql://{user}:{password}@{host}:{port}/{db}?charset={charset}'.format(
@@ -40,7 +43,11 @@ tamp_pay_engine = create_engine(
         port=config[env]['MySQL']['port'],
         user=config[env]['MySQL']['user'],
         password=config[env]['MySQL']['password'],
-        charset="utf8")
+        charset="utf8"),
+    max_overflow=0,  # 超过连接池大小外最多创建的连接
+    pool_size=100,  # 连接池大小
+    pool_timeout=30,  # 池中没有线程最多等待的时间，否则报错
+    pool_recycle=-1  # 多久之后对线程池中的线程进行一次连接的回收（重置）
 )
 
 redis = redis.Redis(
@@ -83,4 +90,3 @@ class TAMP_SQL(object):
             self.session.rollback()
         finally:
             self.session.close()
-