SqlAlchemy et Multiprocessing

Question

J'utilise SqlAlchemy pour me connecter au backend de ma base de données et faire un usage intensif du multitraitement dans mon application Python. Je suis arrivé à une situation qui nécessite de passer une référence d'objet, qui est le résultat d'une requête de base de données, d'un processus à un autre. C'est un problème, car lors de l'accès à un attribut de l'objet, SqlAlchemy tente de rattacher l'objet dans la session en cours de l'autre processus, qui échoue avec une exception, car l'objet est attaché dans une autre session:

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

Quelle est la façon de gérer cette situation? Est-il possible de détacher l'objet de la première session ou de cloner l'objet sans les éléments liés à ORM?

Answer 1

Ceci est une mauvaise idée (tm). Vous ne devez pas partager un objet avec état entre des processus comme celui-ci (je sais que c'est tentant) car toutes sortes de mauvaises choses peuvent arriver puisque les primitives de verrouillage ne sont pas destinées à fonctionner sur plusieurs runtimes python.

je suggère de prendre les attributs dont vous avez besoin de cet objet, les brouillage dans un dict et envoyer tous les processus utilisant Pipes multprocessing:

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