sqlalchemy mysql 烧瓶上的连接未关闭 api

Question

我有一个 api 我用烧瓶写的。它使用 sqlalchemy 来处理 mysql 数据库。我不使用 flask-sqlalchemy，因为我不喜欢模块强制您进入特定模式来声明模型的方式。

我遇到了一个问题，我的数据库连接没有关闭。代表连接的对象超出范围，所以我假设它正在被垃圾收集。我还在会话中明确调用 close() 。尽管有这些事实，在 api 调用返回其响应后很长时间内连接仍保持打开状态。

sqlsession.py：这是我在会话中使用的包装器。

class SqlSession:
    def __init__(self, conn=Constants.Sql):
        self.db = SqlSession.createEngine(conn)

        Session = sessionmaker(bind=self.db)
        self.session = Session()
    @staticmethod
    def createEngine(conn):
        return create_engine(conn.URI.format(user=conn.USER, password=conn.PASS, host=conn.HOST, port=conn.PORT, database=conn.DATABASE, poolclass=NullPool))

    def close(self):
        self.session.close()

flaskroutes.py：这里是flask app实例化和使用wrapper对象的例子。请注意，它在 api 调用的范围内开始实例化它，然后在最后关闭会话，并且大概是在响应返回后被垃圾收集。

def commands(self, deviceId):
    sqlSession = SqlSession(self.sessionType) <---

    commandsQueued = getCommands()
    jsonCommands = []
    for command in commandsQueued:
     jsonCommand = command.returnJsonObject()
     jsonCommands.append(jsonCommand)
     sqlSession.session.delete(command)
    sqlSession.session.commit()
    resp = jsonify({'commands': jsonCommands})
    sqlSession.close() <---  
    resp.status_code = 200
    return resp

我希望在做出 http 响应后立即清除连接，但连接最终以 "SLEEP" 状态结束（在 mysql 命令行界面中查看 'show processlist').

Answer 1

我最终使用了这个 SO post 中的建议： How to close sqlalchemy connection in MySQL

我强烈建议所有遇到此问题的人阅读 post。基本上，我向 close 方法添加了一个 dispose() 调用。这样做会导致整个连接被破坏，而只是关闭 returns 到可用池的连接（但让它们保持打开状态）。

def close(self):
    self.session.close()
    self.db.dispose()

这一切让我有点困惑，但至少现在我对连接池有了更多的了解。

sqlalchemy mysql 烧瓶上的连接未关闭 api

sqlalchemy mysql connections not closing on flask api

python

mysql

database-connection

sqlalchemy

flask