Python如何将消息发布到RabbitMQ
示例
从导入库开始。
from amqpstorm import Connection from amqpstorm import Message
接下来，我们需要打开与RabbitMQ服务器的连接。
connection = Connection('127.0.0.1', 'guest', 'guest')之后，我们需要建立一个频道。每个连接可以有多个通道，通常在执行多线程任务时，建议（但不是必需）每个线程一个。
channel = connection.channel()
建立频道后，我们就可以开始准备信息了。
#邮件属性。
properties = {
'content_type': 'text/plain',
'headers': {'key': 'value'}
}
#创建消息。
message = Message.create(channel=channel, body='Hello World!', properties=properties)现在，我们可以通过简单地调用publish并提供来发布消息routing_key。在这种情况下，我们将把消息发送到名为的队列simple_queue。
message.publish(routing_key='simple_queue')