我在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/