0

我正在构建一个小型 WSGI 应用程序,我遇到了 SQLAlchemy 抛出UnboundExceptionError.

当它发生时,它似乎只发生在浏览器发出的第二个请求上。刷新页面(以及所有后续页面查看尝试)运行良好。它似乎只发生在第二个请求上。

我正在使用很多对我来说是新的技术,所以我并不完全清楚我应该看什么来尝试解决这个问题。

  • CherryPyWSGI服务器
  • 路线
  • AuthKit
  • WebOb
  • SQL炼金术
  • 神社2

这是我的 SQLAlchemy 相关设置:

product_table = Table('product', metadata,
    Column('productId', Integer, primary_key=True),
    Column('name', String(255)),
    Column('created', DateTime, default=func.now()),
    Column('updated', DateTime, default=func.now(),
        onupdate=func.current_timestamp()),
)

productversion_table = Table('productVersion', metadata,
    Column('productVersionId', Integer, primary_key=True),
    Column('productId', Integer, ForeignKey("product.productId"),
        nullable=False),
    Column('name', String(255)),
    Column('created', DateTime, default=func.now()),
    Column('updated', DateTime, default=func.now(),
        onupdate=func.current_timestamp()),
)

sqlalchemy.orm.mapper(Product,
    product_table,
    properties={
        'product_versions':
            sqlalchemy.orm.relation(
               ProductVersion,
                backref='product',
                cascade='all,delete-orphan')})

sqlalchemy.orm.mapper(ProductVersion,
    productversion_table,
    properties={ })

这是我的控制器:

class Base(object):

    def __init__(self, projenv, configuration, protected=True):
        self.protected = protected
        self.projenv = projenv
        self.configuration = configuration
        self.jinja2_env = Environment(
            loader=PackageLoader('my.webapp', 'views'))

    def __call__(self, environ, start_response):
        if self.protected:
            authkit.authorize.authorize_request(environ,
                authkit.permissions.RemoteUser())

        return self.handle_request_wrapper(environ, start_response)

    def handle_request_wrapper(self, environ, start_response):
        request = Request(environ)
        response = Response()
        model_and_view = self.handle_request(request, response)
        if model_and_view['redirect']:
            response = HTTPTemporaryRedirect(
                location=model_and_view['redirect_url'])
        else:
            response.content_type = model_and_view['content_type']
            template = self.jinja2_env.get_template(model_and_view['view'])
            content = template.render(**model_and_view['model'])
            response.body = str(content)
        return response(environ, start_response)


class Product(Base):

    def handle_request(self, request, response):
        model_and_view = Base.handle_request(self, request, response)

        url, match = request.environ['wsgiorg.routing_args']

        product_repository = product_repository_from_config(self.configuration)

        model_and_view['view'] = 'products/product.html'
        model_and_view['model']['product'] = \
            product_repository.get_product(match['product_id'])
        return model_and_view

这是我的产品存储库代码:

def product_repository_from_config(configuration):
    session = session_from_config(configuration)
    return SqlAlchemyProductRepository(session, configuration)

class SqlAlchemyProductRepository(object):
    """SQLAlchemey Based ProductRepository."""

    def __init__(self, session, configuration = None):
        self.configuration = configuration
        self.session = session

    def get_product(self, product_id):
        return self.session.query(Product).filter_by(
            productId=product_id).first()

这是我的 ORM 实用程序:

engines = {}

def setup_session(engine, **kwargs):
    session = sqlalchemy.orm.sessionmaker(bind=engine, **kwargs)
    return session()

def session_from_config(configuration, init=False, **kwargs):
    engine = engine_from_config(configuration, init)
    return setup_session(engine, **kwargs)

def engine_from_config(configuration, init=False):
    """Create an SQLAlchemy engine from a configuration object."""

    config = configuration.to_dict()

    key = pickle.dumps(config)

    if key not in engines:

        engine = sqlalchemy.engine_from_config(configuration.to_dict(),
                prefix = 'db.')

        configure_mapping_for_engine(engine, init)

        engines[key] = engine

    return engines[key]

这是我的观点(jinja2):

{% extends "shell.html" %}
{% set title = "Product - " + product.name %}
{% block content %}
<h1>Product</h1>
<ul>
<li><a href="{{ url_for('products') }}">Product List</a></li>
</ul>
<form method="post" action="{{ url_for('products/update', product_id=product.productId) }}">
Name <input type="text" name="name" value="{{ product.name|e }}" /><br />
<input type="submit" value="Update" />
</form>
<form enctype="multipart/form-data" method="post" action="{{ url_for('products/versions/add', product_id=product.productId) }}">
Version Name <input type="text" name="name" />
<input type="submit" value="Add Version" />
</form>


<ul>
{% for product_version in product.product_versions %}
<li>{{ product_version.name }}
<ul>
<li><a href="{{ url_for('products/versions/delete', product_id=product.productId, product_version_id=product_version.productVersionId) }}">delete</a></li>
</ul>
</li>
{% endfor %}
</ul>
{% endblock %}

我得到的错误是:

UnboundExecutionError: Parent instance <Product at 0x9150c8c> is not bound to a Session; lazy load operation of attribute 'product_versions' cannot proceed

堆栈跟踪显示这是从以下位置抛出的:

{% for product_version in product.product_versions %}

在我从存储库获取实例到模板中的 jinja2 评估它的时间之间,什么可能导致我的实例与 Session 解除绑定?

我倾向于认为这可能是 authkit 调用妨碍了事情,但我不确定它可能会做什么,因为它实际上发生在会话创建之前并且可能不会影响以后发生的任何事情?

4

1 回答 1

3

通常,您应该有一个方案,其中每个请求都存在一个 Session,对于当前线程是本地的,并且仅在请求结束时被拆除(如果有的话,它也可以在下一个请求中重用)。通常,您会在总体请求包装器中看到会话的创建和清理代码,在这种情况下,它可能位于handle_request_wrapper(). 像 authkit 这样的 WSGI 中间件不应该真正访问您自己的应用程序中的会话,除非您以某种方式将它们链接在一起。在上面的所有代码中都没有(编辑:好的,我可以模糊地看到它在哪里设置,在每个请求上创建一个新引擎?永远不要那样做......而且会话可能在请求完成之前得到 gc'ed)当你的指示setup_session()实际调用或在请求进行时返回的会话会发生什么。在任何情况下,由于您没有使用上下文管理器,因此有必要将此单个 Session 传递给请求中涉及的所有函数 - 因为如果它是一个全局对象,您将获得并发线程同时访问它,这将导致立即问题 - 这是一个非常麻烦的模式。

提供的scoped_session目的是使“每个线程的会话”模式超级简单,并且在使用 Pylons 时默认设置“请求边界上的设置/拆除”模式。此生命周期的可视化(尽管是 ASCII)说明位于http://www.sqlalchemy.org/docs/05/session.html#lifespan-of-a-contextual-session

于 2010-01-14T06:33:29.393 回答