Как реализовать многопроцессорную обработку сообщений из очереди?

Question

[Mr_Sinister]

Добрый вечер. Подскажите, как можно реализовать многопроцессорную обработку сообщений, получаемых из RabbitMQ? Использую модуль Pika.
Создавать в каждом процессе соединение не вариант (оно должно быть одно и находиться в родительском процессе). При этом должен быть доступ к каналу, чтобы уведомлять брокер об ack/nack и отправлять результат в другую очередь.

Comments

[agladkov]

https://docs.python.org/dev/library/multiprocessin...

apply_async - для обработки сообщения
callback - для обработки результата
Можно результат еще через очередь возвращать (Queue)