複数のデータベースシャーディングを持つSQLAlchemy宣言型モデル

Question

私のデータベースを2つに分割しようとしています。今、私のコードは次のようになります：

engine = create_engine('postgresql+psycopg2://postgres:password@localhost:5432/logs') 
engine2 = create_engine('postgresql+psycopg2://postgres:password@localhost:5432/logs') 
DBSession = scoped_session(sessionmaker(extension=ZopeTransactionExtension())) 
binds = {'thing': engine, 
    'log': engine_a} 
DBSession.configure(binds=binds) 
Base = declarative_base(bind=engine) 
Base2 = declarative_base(bind=engine2) 

class Thing(Base): 
    ... 

class Log(Base2): 
    ... 

ここでは、BaseとBase2の両方を継承したオブジェクトを使用しているテーブルが増えています。私も次の操作を実行しようとしました：

DBSession = scoped_session(sessionmaker(extension=ZopeTransactionExtension(), bind=engine)) 
DBSession2 = scoped_session(sessionmaker(extension=ZopeTransactionExtension(), bind=engine2)) 

しかし、問い合わせるときに、私は次のエラーを取得する、のいずれかの方法を使用し、唯一のベースではなく、BASE2内のオブジェクトを扱う：

return DBSession.query(cls).filter(func.lower(cls.name) == name.lower()).first() 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/scoping.py", line 113, in do 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/session.py", line 969, in query 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/query.py", line 107, in __init__ 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/query.py", line 116, in _set_entities 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/query.py", line 131, in _setup_aliasizers 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/util.py", line 550, in _entity_info 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/mapper.py", line 2861, in configure_mappers 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/mapper.py", line 1166, in _post_configure_properties 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/interfaces.py", line 128, in init 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/properties.py", line 913, in do_init 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/orm/properties.py", line 969, in _process_dependent_arguments 
    File "build/bdist.macosx-10.7-intel/egg/sqlalchemy/ext/declarative.py", line 1346, in return_cls 
    File "<string>", line 1, in <module> 
AttributeError: 'Table' object has no attribute 'id' 

もちろん私テーブルに属性 'id'がある場合、DBSessionが1つとBaseが1つのみであれば、同じコードがすべて機能します。私は間違って何をしていますか？

Answer 1

私はこの問題を発見しました。私は単にDBSession()を開始しなければなりませんでした。