SqlAlchemy and Multiprocessing

Question

Używam SqlAlchemy do łączenia się z moim zapleczem bazy danych i intensywnego korzystania z wieloprocesowości w mojej aplikacji Python. Doszedłem do sytuacji, która wymaga przekazania referencji do obiektu, która jest wynikiem zapytania do bazy danych, z jednego procesu do drugiego.

Jest to problem, ponieważ podczas uzyskiwania dostępu do atrybutu obiektu, SqlAlchemy próbuje ponownie dołączyć obiekt do bieżącej sesji innego procesu, który kończy się niepowodzeniem z wyjątkiem, ponieważ obiekt jest dołączony do innej sesji:

InvalidRequestError: Object '<Field at 0x9af3e4c>' is already attached to session '148848780' (this is '159831148') 

Jaki jest sposób poradzenia sobie z taką sytuacją? Czy możliwe jest odłączenie obiektu od pierwszej sesji lub sklonowanie obiektu bez obiektów związanych z ORM?

Answer 1

To jest zły pomysł (tm).

Nie należy udostępniać obiektu stanowego między procesami takimi jak ten (wiem, że to kuszące), ponieważ mogą wystąpić wszystkie złe rzeczy, ponieważ prymitywy blokujące nie są przeznaczone do pracy w wielu środowiskach pythona.

Proponuję biorąc atrybuty potrzebne z tego obiektu, zagłuszania ich do dict i wysłaniem go między procesami za pomocą multprocessing Rury

http://docs.python.org/library/multiprocessing.html#pipes-and-queues