如何将消息从Flask服务器发送到RabbitMQ服务器队列

Question

我正试图从充当生产者的Flask服务器向RabbitMQ服务器队列发送一条消息。我用来生成消息的端口是"5672"。

我在RabbitMQ的管理服务器上创建了一个交换和一个队列，主要目标是在服务器的队列中接收消息。

这是我目前拥有的代码，它不会产生任何错误，并返回消息已发送：

@app.route("/create/<message>")
def create_bucket(message):
credentials = pika.PlainCredentials("guest", "guest")
connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost", credentials=credentials))
channel = connection.channel()
channel.queue_declare(queue="TestQueue", durable=True)
channel.basic_publish(exchange="TestExchange", routing_key="TestQueue", body=message, properties=pika.BasicProperties(delivery_mode=2))
connection.close()
return "[x] Message sent %s" % message 
if __name__ == "__main__":
app.run(debug=True, port=5672)

尽管该消息没有出现在RabbitMQ的服务器队列中。

是否有任何资源或方法可以将消息从Flask的服务器发送到RabbitMQ的服务器队列？

Answer 1

由于routing_key未在RabbitMQ服务器中声明，因此通过删除routing_key="TestQueue"设法解决了问题。