我在PythonAnywhere上有一个网站,该网站使用Flask和Flask-SQLAlchemy连接到MySQL数据库。用户可以使用网站对作为表中记录保存到数据库的任务进行排队,然后单独的计划任务(Python程序)检查数据库并处理所有未处理的记录。

我遇到的问题是,计划任务的db查询似乎仅在第一次运行时才找到新记录,但是如果我随后使用该网站添加新任务,则仍在运行的计划任务的重复db查询(每5秒钟)似乎没有检测到新记录。

关于这里可能发生什么的任何想法?

这是bash文件运行的代码:

def generate_any_pending_videos():
    unfinished_videos = db.session.query(Video)\
                                  .filter(~Video.status.has(VideoStatus.status.in_(['Error', 'Finished', 'Video deleted'])))\
                                  .order_by(Video.datetime_created)\
                                  .all()
    for video in unfinished_videos:
        try:
            logging.info("Attempting to create video for video %d" % video.id)
            generate_video(video)
        except Exception as e:
            logging.error(str(e))


if __name__ == '__main__':
    while True:
        generate_any_pending_videos()
        time.sleep(5)

最佳答案

默认情况下,所有SqlAlchemy查询都在事务内运行http://docs.sqlalchemy.org/en/latest/orm/session_transaction.html。这就是您在脚本的第一次调用中仅获取新数据的原因。因为在事务内部看到的数据不会改变,即ACID中的I,所以事务是隔离的。
   在提交或回滚之后,下一个查询将启动新的事务,因此您将从数据库中获取新数据。

关于python - Flask-SQLAlchemy session 对象没有看到对数据库的更改?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52156515/

10-10 20:57
查看更多