Как переиздавать сообщения с pika и RabbitMQ

Question

Мне нужно слушать сообщения RabbitMQ, обрабатывать каждое сообщение немного, и отправить его на другой обмен. Каждый пример я видел до сих пор включает в себя как это:

reader_connection.ioloop.start() 

или это:

writer_connection.ioloop.start() 

Потому что мне нужно как получать и отправлять сообщения, я, вероятно, нужно запустить обе петли одновременно. Есть ли способ, которым я мог бы это сделать?

Answer 1

Между издателями и подписчиками нет никакой разницы. Вы можете публиковать и подписываться с использованием одного и того же соединения или другого (тогда вам нужно будет запустить ioloop для них обоих) Здесь вы можете найти несколько примеров: https://pika.readthedocs.org/en/0.10.0/examples/connecting_async.html