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 开发网站时如何管理数据库连接

8 回复

我以为 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 小姐姐,笔记做好了。

说,你是不是公务员转行的开发

哈哈哈,标题有趣。

打算转公务员了,提前练习下官腔。

回到顶部