Как публиковать сообщения на RabbitMQ

Начните с импорта библиотеки.

 from amqpstorm import Connection
from amqpstorm import Message

 

Далее нам нужно открыть соединение с сервером RabbitMQ.

 connection = Connection('127.0.0.1', 'guest', 'guest')

 

После этого нам нужно настроить канал. Каждое соединение может иметь несколько каналов, и, как правило, при выполнении многопоточных задач рекомендуется (но не обязательно) иметь один канал на поток.

 channel = connection.channel()

 

Как только мы настроим наш канал, мы можем начать готовить наше сообщение.

 # Message Properties.
properties = {
    'content_type': 'text/plain',
    'headers': {'key': 'value'}
}

# Create the message.
message = Message.create(channel=channel, body='Hello World!', properties=properties)

 

Теперь мы можем опубликовать сообщение, просто вызывая publish и обеспечение routing_key . В этом случае мы будем посылать сообщение в очередь , называется simple_queue .

 message.publish(routing_key='simple_queue')