sqlalchemy mysql连接未在flask 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：这是一个烧瓶应用程序实例化和使用包装器对象的示例。注意它在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 帖子中的建议： How to close sqlalchemy connection in MySQL

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

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

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