python - 如何使用 SQLAlchemy 无缝访问多个数据库？

Question

假设我为公司的不同部门创建了一个产品数据库系统。由于各种原因，每个部门都有自己的 PostgreSQL 数据库实例。数据库的模式是相同的，但它们中的数据不同。对于这些系统中的每一个，都存在一个执行某些业务逻辑（无关）的 Python 应用程序。每个 Python 应用程序都通过 SQLAlchemy 访问其并且仅访问其数据库。

我想创建一个主管系统，可以访问所有这些数据库中的所有数据（通读功能）。

这是我的想法的一个例子：

我可以用 SQLAlchemy 做到这一点吗？如果是这样，解决这类问题的最佳方法是什么？

Answer 1

当然你可以用 SQLAlchemy 做到这一点。

您需要做的就是创建不同的连接引擎，每个引擎都有自己的会话生成器。SQLAlchemy 中的任何内容都不会限制您一次只能使用一个数据库。

engines = []
sessions = []
for dbconninfo in databases:
    engine = create_engine(dbconninfo)
    engines.append(engine)
    sessions.append(sessionmaker(bind=engine)())

您可以使用每个会话来运行查询，结果对象附加到生成它们的会话，以便更改流回正确的数据库。一定要详细研究会话文档，看看如果你将一个对象从一个会话合并到另一个会话中会发生什么，例如。