python连接pika发送mq消息

要使用Python连接pika发送MQ消息，你首先需要安装pika库。可以使用以下命令安装：

pip install pika

安装完成后，你可以使用以下代码来连接MQ服务器并发送消息：

import pika

# 连接MQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

# 创建一个队列
channel.queue_declare(queue='my_queue')

# 发送消息
channel.basic_publish(exchange='', routing_key='my_queue', body='Hello, World!')

# 关闭连接
connection.close()

在上述代码中，我们首先创建了一个连接对象并通过它创建了一个通道，然后声明了一个队列，最后使用 `basic_publish()` 方法来发送消息。该方法的三个参数分别表示消息的交换机、路由键和消息体。在本例中，我们使用空字符串作为交换机，因为我们只是将消息发送到指定的队列中。在发送完消息后，我们关闭了连接对象。