读取从站，读写主站设置

Question

我有一个Flask，SQLAlchemy
webapp，它使用一个mysql服务器。我想将数据库设置扩展为具有只读从​​属服务器，以便可以在继续写入主数据库服务器的同时在主服务器和从属服务器之间分散读取。

我研究了几种选择，我相信我无法使用普通的SQLAlchemy做到这一点。我打算在我的web应用程序中创建2个数据库句柄，每个用于主数据库服务器和从数据库服务器。然后，使用简单的随机值，将主/从数据库句柄用于“
SELECT”操作。

但是我不确定这是否是使用SQLAlchemy的正确方法。关于如何实现这一目标的任何建议/提示？提前致谢。

Answer 1

我在http://techspot.zzzeek.org/2012/01/11/django-style-database-routers-in-
sqlalchemy/
上的博客中提供了有关如何执行此操作的示例。基本上，您可以增强会话，以便在逐个查询的基础上从主服务器或从服务器中进行选择。这种方法的一个潜在故障是，如果您有一个事务调用了六个查询，那么您可能最终会在一个请求中使用两个从属....但是我们只是在尝试模仿Django的功能:)

一种稍微少用的魔术方法（也可以更明确地确定使用范围）是视图可调用项（无论在Flask中如何调用）的装饰器，如下所示：

@with_slave
def my_view(...):
   # ...

假设您有一个Session并设置了一些引擎，with_slave会做类似的事情：

master = create_engine("some DB")
slave = create_engine("some other DB")
Session = scoped_session(sessionmaker(bind=master))

def with_slave(fn):
    def go(*arg, **kw):
        s = Session(bind=slave)
        return fn(*arg, **kw)
    return go

这个想法是，调用将Session(bind=slave)调用注册表以获取当前线程的实际Session对象，如果不存在则创建它-
但是，由于我们传递了一个参数，scoped_session将断言我们在此处创建的Session是绝对是全新的。

您将其指向所有后续SQL的“从属”。然后，当请求结束时，您将确保Flask应用正在调用Session.remove()以清除该线程的注册表。下次在同一线程上使用注册表时，它将是绑定到“主服务器”的新会话。

或一个变体，您只想为该调用使用“从属”，这是“安全的”，因为它将所有现有的绑定还原回Session：

def with_slave(fn):
    def go(*arg, **kw):
        s = Session()
        oldbind = s.bind
        s.bind = slave
        try:
            return fn(*arg, **kw)
        finally:
            s.bind = oldbind
    return go

对于这些装饰器中的每个装饰器，您都可以撤消操作，将会话绑定到“从属”，其中装饰器将其置于“主”上以进行写操作。如果在这种情况下您想要一个随机的奴隶，那么如果Flask发生某种“请求开始”事件，您可以在那时进行设置。