OpenStack平台集成指南
1. 使用Kombu监听Nova队列
在OpenStack环境中,我们可以使用Python的Kombu库来连接消息总线的Nova队列,监听不同Nova服务之间的RPC调用。以下是具体的操作步骤:
1.定义回调方法:用于处理消息总线上的事件,这里的简单方法只是打印消息体。
from kombu import Connection, Exchange, Queue def process_message(body, message): print body message.ack()- 创建队列并绑定到交换器:创建一个名为
listener的队列,并将其绑定到nova交换器,订阅nova队列上的所有消息。
nova_exchange = Exchange('nova', 'topic', durable=False) nova_queue = Queue('listener', exchange=nova_exchange, routing_key='#') conn = Connection('amqp://guest:guest@192.168.0.10//') consumer = conn.Consumer(nova_queue, ca