python rabbitMQ使用者，它使用消息并调用作为后台进程运行的API

Question

我有一个简单的用例，我想使用来自RabbitMQ服务器的消息，这些消息由第三方应用程序生成，每当它们生成任何消息时，我都希望我的消费者收到它并进行API调用。

我有下面的脚本来解决这个问题，但我不确定它是否是生产级别的解决方案，有没有任何方法可以改进它，或者如果我在主管的帮助下在后台运行这个脚本，它会正常工作吗。

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', 
pika.PlainCredentials("user", "pass")))
channel = connection.channel()
def callback(ch, method, properties, body):
#Makes an API call
channel.basic_consume(queue="notifications.info", on_message_callback=callback, auto_ack=True)
channel.start_consuming()

Answer 1

是的，差不多。对于生产，您可以实现multiprocessing和多个消费者来扩展解决方案。