当我使用@Observers时，会话已经刷新

Question

我正在构建一个flask应用程序，我想使用sqlalchemyobservers来更新装运状态，一旦该装运中的所有产品都可用。在

以下是我的数据模型：

from app import db
from sqlalchemy_utils import observes

class Shipment(db.Model):
    __tablename__ = 'shipment'
    id = db.Column(db.Integer, primary_key=True)
    products = db.relationship('Product', backref='shipment', lazy='dynamic')
    all_products_ready = db.Column(db.Boolean)

    @observes('products')
    def product_observer(self, products):
        for p in self.products:
            if p.status != 'ready':
                self.all_products_ready = False
                return False
        self.all_products_ready = True
        return True

class Product(db.Model):
    __tablename__ = 'product'
    id = db.Column(db.Integer, primary_key=True)
    shipment_id = db.Column(db.Integer, db.ForeignKey('shipment.id'))

    status = db.Column(db.String(120), index=True)

下面是我运行的一些代码来测试它：

^{pr2}$

当我运行这个代码时，我得到一个InvalidRequestError:Session已经刷新了。在

下面是堆栈跟踪：

Traceback (most recent call last):
  File "test.py", line 5, in <module>
    db.session.commit()
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\scoping.py",
line 150, in do
    return getattr(self.registry(), name)(*args, **kwargs)
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 788, in commit
    self.transaction.commit()
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 384, in commit
    self._prepare_impl()
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 364, in _prepare_impl
    self.session.flush()
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 1985, in flush
    self._flush(objects)
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 2012, in _flush
    self.dispatch.before_flush(self, flush_context, objects)
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\event\attr.py", l
ine 221, in __call__
    fn(*args, **kw)
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy_utils\observer.py
", line 272, in invoke_callbacks
    for (root_obj, func, objects) in args:
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy_utils\observer.py
", line 252, in gather_callback_args
    lambda obj: obj not in session.deleted
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy_utils\functions\o
rm.py", line 741, in getdotattr
    last = [v for v in last if condition(v)]
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\dynamic.py",
line 245, in __iter__
    sess = self.session
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\dynamic.py",
line 237, in session
    sess.flush()
  File "U:\dev\observertest\flask\lib\site-packages\sqlalchemy\orm\session.py",
line 1979, in flush
    raise sa_exc.InvalidRequestError("Session is already flushing")
sqlalchemy.exc.InvalidRequestError: Session is already flushing

如何使用模型而不出现此错误？在

Answer 1

我不完全确定原因，但我认为使用dynamic加载关系会引起问题。在这一行中：

    products = db.relationship('Product', backref='shipment', lazy='dynamic')

您需要将lazy参数改为select，而不是dynamic（或者可以去掉{}参数，因为{}是其默认值）。在

有关所有可用选项，请参见the sqlalchemy reference。在