SqlAlchemy và Multiprocessing

Question

Tôi sử dụng SqlAlchemy để kết nối với backend cơ sở dữ liệu của mình và sử dụng nhiều khả năng đa xử lý trong ứng dụng Python của tôi. Tôi đã đến một tình huống mà yêu cầu phải vượt qua một tham chiếu đối tượng, đó là kết quả của một truy vấn cơ sở dữ liệu, từ một tiến trình này sang tiến trình khác. Đây là một vấn đề, bởi vì khi truy cập vào một thuộc tính của đối tượng, SqlAlchemy trys để reattach đối tượng vào phiên hiện tại của quá trình khác, mà không có ngoại lệ, bởi vì đối tượng được đính kèm trong một phiên khác:

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

Cách xử lý tình huống này là gì? Có thể tách đối tượng khỏi phiên đầu tiên hoặc sao chép đối tượng mà không có các công cụ liên quan đến ORM không?

Answer 1

Đây là một ý tưởng tồi (tm). Bạn không nên chia sẻ một đối tượng stateful giữa các quá trình như thế này (tôi biết nó là hấp dẫn) bởi vì tất cả các loại điều xấu có thể xảy ra kể từ khóa nguyên thủy không có ý định làm việc trên nhiều runtimes python.

Tôi đề nghị dùng các thuộc tính bạn cần phải ra ngoài của đối tượng đó, gây nhiễu chúng thành một dict và gửi nó qua quá trình sử dụng ống multprocessing:

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