开发者

sqlalchemy session not recognizing changes in mysql database (done by other processes)

Application consists of:

  • main process (python+sqlalchemy) that periodically check db (sleeps most of the time)
  • child processes that write to db
  • web app that write to db

Problem is that the main process session doesn't seem to register changes in the db done outside that sessio开发者_运维技巧n. How do ensure it does? (as of now I am closing and reopening the session every time the process awakes and does its check).


I am closing and reopening the session every time the process awakes and does its check

SQLAlchemy will not work like this. Changes are tracked in the session.

someobj = Session.query(SomeClass).first()

puts someobj into Session internal cache. When you do someobj.attr = val, it marks the change in the Session associated with someobj.

So if you pulled object1 from some session1, then closed session1, object1 is not associated with any session anymore and is not tracked.

Best solution would be to commit right upon the change:

object1 = newsession.add(object1)
newsession.commit()

Otherwise you will have to manage own objects cache and merge all of them upon each check.

0

上一篇:

下一篇:

精彩评论

暂无评论...
验证码 换一张
取 消

最新问答

问答排行榜