SQLAlchemyを使用して複数のデータベースにシームレスにアクセスするには？

Question

私の会社の異なる部門の製品データベースシステムを作成したとします。各部門にはさまざまな理由で独自のPostgreSQL-databse-instanceがあります。データベースのスキーマは同じですが、それらのデータは異なります。これらのシステムのそれぞれに対して、ビジネスロジックを行うPythonアプリケーションが存在します（無関係）。各Pythonアプリケーションは、SQLAlchemyを介してデータベースにアクセスします。

これらすべてのデータベースのすべてのデータにアクセスできるスーパービジターシステムを作成したい（読取り機能）。ここで

は私が考えるものの例である：

私はSQLAlchemyのであることを行うことができますか？もしそうなら、そのような問題のための最良のアプローチは何ですか？

Answer 1

確かに、SQLAlchemyを使用することができます。

あなたが行う必要があるのは、それぞれ独自のセッションメーカーを持つ異なる接続エンジンを作成することだけです。 SQLAlchemyでは、一度に1つのデータベースに制限されるものはありません。あなたは、クエリを実行するために、各セッションを使用することができます

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

変更が正しいデータベースに逆流するように、結果オブジェクトは、それらを生成するセッションに接続されています。 session documentationを詳細に調べて、あるセッションから別のセッションにオブジェクトをマージする場合にどうなるかを確認してください。