如何在Sqlalchemy orm会话中正确禁用缓存？

Question

我在一个守护进程中执行线程，该守护进程循环并执行以下查询：

    try:
        newsletter = self.session.query(models.Newsletter).\
               filter(models.Newsletter.status == 'PROCESSING').\
               limit(1).one()
    except sa.orm.exc.NoResultFound:
        self.logger.debug('No PROCESSING newsletters found. Sleeping...')
        self.sleep()
        return
    # (...) more code to do with found newsletter

其中，睡眠方法只是在配置的时间内停止该线程的执行，并且return语句返回到主循环。然而，我发现，如果我在守护进程运行时将任何时事通讯的状态更改为“正在处理”，则没有任何反应。查询仍会引发NoResultFound。但是，如果我重新启动守护进程，它将找到时事通讯。所以我明白了，这个查询的结果必须被缓存。我能做什么来使缓存无效？session.expire_all()不起作用。我也可以在每次迭代中创建新的Session()对象，但不知道这对于系统资源来说是否是一个好方法。

Answer 1

SQLAlchemy doesn't cache本身。除非您显式实现了缓存like this one。

将echo=True传递给您的sessionmaker并查看logging output。

Answer 2

代码中的问题是由于默认情况下数据库使用REPEATABLE READ isolation level造成的，所以查询返回相同的结果，除非您调用commit()或rollback() (或按照Xeross的建议使用autocommit=True )或手动更改隔离级别。

是的，SQLAlchemy确实缓存映射对象(而不是查询结果！)，因为ORM模式要求每个身份都有一个对象。默认情况下，SQLAlchemy使用弱身份映射作为缓存，因此当没有对对象的引用时，对象会自动从会话中删除。请注意，后续查询将使用新数据更新缓存对象的状态，因此无需担心此缓存。

Answer 3

嗯，我已经找到了答案，你显然需要显式地执行session.commit()来更新它，或者你需要在会话上设置autocommit=True，例如通过会话生成器。

sessionmaker(bind=self.engine, autocommit=True)

但是，我还没有测试session.commit()方法

所以这不是缓存问题，而是事务的工作方式