python - sqlalchemy mysql 连接没有在 flask api 上关闭

Question

我有一个用 Flask 编写的 API。它使用 sqlalchemy 来处理 MySQL 数据库。我不使用 flask-sqlalchemy，因为我不喜欢模块强制您采用特定模式来声明模型的方式。

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

sqlsession.py:这是我用于 session 的包装器。

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 应用程序实例化和使用包装器对象的示例。请注意，它在 api 调用的范围内开始实例化它，然后在结束时关闭 session ，并且大概是在返回响应后进行垃圾收集。

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 命令行界面“显示进程列表”中查看时)。

Answer 1

我最终使用了这篇 SO 帖子中的建议: How to close sqlalchemy connection in MySQL

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

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

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