Openstack中使用rabbitmq获取vm状态变化

#!/usr/bin/env python
import pika
import json
 
credentials = pika.PlainCredentials(‘xxx‘, ‘xxx‘)
params = pika.ConnectionParameters(host=‘xxx‘,credentials=credentials)
connection = pika.BlockingConnection(params)
channel = connection.channel()
 
exchange_name = ‘nova‘
queue_name = channel.queue_declare(exclusive=True).method.queue
binding_key = ‘notifications.info‘
 
channel.exchange_declare(exchange=exchange_name,type=‘topic‘)
channel.queue_bind(exchange=exchange_name,
queue=queue_name,
routing_key=binding_key)
 
print ‘ [*] Waiting for logs. To exit press CTRL+C‘
 
def callback(ch, method, properties, body):
b= json.loads(body)
print b[‘event_type‘],b[‘payload‘][‘state‘], b[‘payload‘][‘old_state‘]
# for key,value in b.iteritems():
# print key,‘:‘,value
 
channel.basic_consume(callback,queue=queue_name,no_ack=True)
channel.start_consuming()