python - 使用 SqlAlchemy 在无限循环中获取新结果

Question

我是 Python 新手 - 来自 PHP - 并且一直在 Python 官方文档和 SqlAlchemy(我试图像 Laravel 的 DB 类一样轻松地使用它)之间来回切换

我有这段代码:

from sqlalchemy import *
engine = create_engine('mysql://root:pass==@aws.com/db')
db_connection = engine.connect()
meta = MetaData()
video_processing = Table('video_processing', meta, autoload=True, autoload_with=engine)

while True:
    sleep(1)
    stmt = select([video_processing]).where(video_processing.c.finished_processing ==  0).where(video_processing.c.in_progress == 0)

    result = db_connection.execute(stmt)

    rows = result.fetchall()


    print len(rows)

    stmt = None
    result = None
    rows = None

当我执行语句时，我让它运行并打印出它获取的行数。在此过程中，我进入并从数据库中删除行。问题是，即使我重置了几乎所有我能想到的与查询相关的内容，它仍然在循环的每次迭代中打印出相同数量的获取行，即使我正在更改基础数据。有什么想法吗？

Answer 1

棘手的部分是，如果将 engine.connect() 与 db_connection.close() 一起使用，则需要关闭连接，否则您可能看不到新的数据更改。

我最终绕过了连接并直接在引擎上执行我的语句，无论如何这在逻辑上更有意义:

result = engine.execute(stmt)