python-Flask API上的sqlalchemy mysql连接未关闭

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python-Flask API上的sqlalchemy mysql连接未关闭，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1738字，纯文字阅读大概需要3分钟。

内容图文

我有用烧瓶写的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”中查看时).

解决方法:

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

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

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

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

内容总结

以上是互联网集市为您收集整理的python-Flask API上的sqlalchemy mysql连接未关闭全部内容，希望文章能够帮你解决python-Flask API上的sqlalchemy mysql连接未关闭所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端