相关疑难解决方法(0)

按照我们在如何关闭MySQL中的sqlalchemy连接中所评论的内容,我正在检查SQLAlchemy在我的数据库中创建的连接,并且我无法在不退出Python的情况下关闭它们.

如果我在python控制台中运行此代码,它将保持会话打开,直到我退出python:

from sqlalchemy.orm import sessionmaker
from models import OneTable, get_engine

engine = get_engine(database="mydb")
session = sessionmaker(bind=engine)()

results = session.query(OneTable.company_name).all()

# some work with the data #

session.close()

我发现关闭它的唯一解决方法是engine.dispose()在最后调用.

根据我上面给出的链接中的评论,我现在的问题是:

• 为什么有engine.dispose()必要结束会议？
• 还session.close()不够吗？

我想知道什么是关闭所有mysql连接的正确方法sqlalchemy.对于上下文,它是一个Flask应用程序,所有视图共享同一个session对象.

engine = create_engine("mysql+pymysql://root:root@127.0.0.1/my_database")

make_session = sessionmaker(bind=engine, autocommit=False)

session = ScopedSession(make_session)()

当应用程序被拆除时,它将session被关闭并被engine丢弃

session.close()
engine.dispose()

但根据数据库日志,我仍然有很多错误[Warning] Aborted connection 940 to db: 'master' user: 'root' host: '172.19.0.7' (Got an error reading communication packets).

我已经尝试了一些解决方案,包括电话gc.collect()和engine.pool.dispose()但没有成功...

我怀疑场景后引擎仍然打开了一些连接,需要关闭它们.无论如何列出引擎打开的所有会话/连接？

花了很多时间在这上面,任何建议/帮助/指针将非常感谢!谢谢.

PS:dispose和close调用的灵感来自于如何在MySQL中关闭sqlalchemy连接.顺便问一下,什么是"签出"连接？

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