falcon-sqla 0.4.0

配置

• 创建一个 SQLAlchemy 引擎。

• 将引擎传递给 Manager() 初始化函数的第一个参数。

• 如果将管理器用作中间件组件，请将其 middleware 属性传递给 falcon.App 的中间件列表

engine = create_engine('dialect+driver://my/database')
manager = falcon_sqla.Manager(engine)

app = falcon.App(middleware=[manager.middleware])

# The database session will be available as req.context.session

上下文管理器

falcon_sqla.Manager 还可以使用 session_scope() 上下文管理器显式提供数据库会话

# Somewhere inside a responder
with self.manager.session_scope(req, resp) as session:
    # Use the session
    # <...>

session_scope() 还可以在请求-响应周期之外作为独立的会话上下文使用

with self.manager.session_scope() as session:
    # Use the session
    # <...>

自定义垂直分区

默认支持简单的随机选择读和写数据库副本。使用 add_engine() 方法指示 Manager 在运行时绑定选择逻辑中包含提供的引擎

manager = falcon_sqla.Manager(engine)

read_replica = create_engine('dialect+driver://my/database.replica')
manager.add_engine(read_replica, 'r')

可以通过重写 Manager.get_bind() 方法来实现更复杂用例的定制引擎选择逻辑。

另请参阅此 SQLAlchemy 菜谱：自定义垂直分区。