|
|
@@ -19,6 +19,7 @@ connect_args = {}
|
|
|
database_url = db_settings.database_url
|
|
|
engine = create_engine(
|
|
|
database_url,
|
|
|
+ pool_pre_ping=True, # 设置心跳
|
|
|
connect_args=connect_args,
|
|
|
poolclass=QueuePool,
|
|
|
pool_size=db_settings.DB_POOL_SIZE,
|
|
|
@@ -32,6 +33,7 @@ async_database_url = db_settings.async_database_url
|
|
|
async_engine = create_async_engine(
|
|
|
async_database_url,
|
|
|
connect_args=connect_args,
|
|
|
+ pool_pre_ping=True, # 设置心跳
|
|
|
poolclass=AsyncAdaptedQueuePool,
|
|
|
pool_size=db_settings.DB_POOL_SIZE,
|
|
|
pool_recycle=db_settings.DB_POOL_RECYCLE,
|