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：这是实例化flask应用程序并使用包装对象的示例。请注意，它会在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文章中的建议： 如何在MySQL中关闭sqlalchemy连接

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

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

整个过程让我有些困惑，但是至少现在我对连接池有了更多的了解。