Python 开发网站时如何管理数据库连接
当前系统使用的是 tornado 框架,结构也很简单 V-M 两层设计。现在想重新做个方案,将数据库相关操作向后迁移(在 handler 层不牵扯数据库的任何操作),设计为 V-C-M 层,当前方案在 V 层中,使用了 sqlalchemy 的 [@event](/user/event).listens_for() 的方式对数据库的 db_session 进行管理,类似于:
def session():
[@event](/user/event).listens_for(self.db_session, 'after_commit')
def receive_after_commit(session):
self._close_db_session = False
[@event](/user/event).listens_for(self.db_session, 'after_flush')
def receive_after_begin(session, trans, con):
self._close_db_session = True
现在想在M层开辟一个驱动层,作为 M 层的数据管理 API 提供者,同时也作为该系统内 model 对象的会话管理者。在驱动层,打算对每个前端申请的 session 进行单独管理(没有使用连接池,也不太清楚连接池是否更为适用), 利用
with closing(session):
session.query(NB).filter(...)
来代替之前的条件触发管理机制,也就是说每次 session 任务完成后立刻退出。但是担心这样的话,对于网站,每天都有大量的访问进来,会不会对数据库造成较大压力(因为一次访问可能存在着大量的数据库连接创建与断开)。 或着说这两种都不太合适,有更好的设计方式,请帮忙解答下。
另外鄙人建了个 Python 的学习群 902788038,大家一起学习探讨,另外也有一群 HR 小姐姐可以提供好的就业机会,欢迎加入。
Python 开发网站时如何管理数据库连接
我以为 ZF 新出台了一个文件
在Python开发网站时,管理数据库连接的核心是使用连接池,避免为每个请求都新建/关闭连接。最常用的方式是通过ORM(如SQLAlchemy、Django ORM)或异步驱动(如asyncpg、aiomysql)来管理。
以Flask + SQLAlchemy为例,一个典型的配置如下:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy.pool import QueuePool
app = Flask(__name__)
# 关键配置:使用连接池
app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql://user:pass@localhost/db'
app.config['SQLALCHEMY_ENGINE_OPTIONS'] = {
'poolclass': QueuePool,
'pool_size': 10, # 连接池保持的连接数
'max_overflow': 20, # 超出pool_size后最多创建的连接数
'pool_recycle': 3600, # 连接回收时间(秒)
'pool_pre_ping': True # 执行前轻量级ping检测连接有效性
}
db = SQLAlchemy(app)
@app.route('/')
def index():
# 每个请求会自动从连接池获取/释放连接
users = db.session.query(User).all()
return str(users)
对于异步框架(如FastAPI + asyncpg),连接池管理更关键:
from fastapi import FastAPI
import asyncpg
app = FastAPI()
pool = None
@app.on_event("startup")
async def startup():
global pool
# 创建连接池
pool = await asyncpg.create_pool(
'postgresql://user:pass@localhost/db',
min_size=5, # 最小连接数
max_size=20 # 最大连接数
)
@app.on_event("shutdown")
async def shutdown():
await pool.close()
@app.get("/users")
async def get_users():
async with pool.acquire() as conn: # 从池中获取连接
return await conn.fetch("SELECT * FROM users")
简单总结:用连接池,别自己造轮子。
哈哈,看来是标题吸引了各位啊,不过我还是想请教一下,你们在使用 tornado 框架的时候,是如何管理数据库连接的,触发式还是利用上面的上下文,我看来,触发式的好处就是一个连接可以处理多个数据库请求,而上下文的方式则是一个连接处理一个请求然后就断掉了,数据量大的时候可能会增加数据库的压力,不过再想想 tornado 框架的异步特性,我也觉得都完全 OK 的,或着你们有没有什么好的方式呢,推荐一下,非常感谢。
一群 HR 小姐姐,笔记做好了。
说,你是不是公务员转行的开发
哈哈哈,标题有趣。
打算转公务员了,提前练习下官腔。

