RabbitMQ 라우팅

원하는 메세지만 선택해서 받기 위한 기능.

exchange와 큐를 바인딩하기위해 routing_key 매개변수를 이용함.

예제소스

emit_log_direct.py

#!/usr/bin/env python import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='direct_logs', type='direct') severity = sys.argv[1] if len(sys.argv) > 1 else 'info' message = ' '.join(sys.argv[2:]) or 'Hello World!' channel.basic_publish(exchange='direct_logs', routing_key=severity, body=message) print " [x] Sent %r:%r" % (severity, message) connection.close()

receive_logs_direct.py

#!/usr/bin/env python import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='direct_logs', type='direct') result = channel.queue_declare(exclusive=True) queue_name = result.method.queue severities = sys.argv[1:] if not severities: print >> sys.stderr, "Usage: %s [info] [warning] [error]" % \ (sys.argv[0],) sys.exit(1) for severity in severities: channel.queue_bind(exchange='direct_logs', queue=queue_name, routing_key=severity) print ' [*] Waiting for logs. To exit press CTRL+C' def callback(ch, method, properties, body): print " [x] %r:%r" % (method.routing_key, body,) channel.basic_consume(callback, queue=queue_name, no_ack=True) channel.start_consuming()

테스트 방법 

먼저 recevier  2개 실행

python receive_logs_direct.py warning error > logs_from_rabbit.log

python receive_logs_direct.py info warning error

로그 발행

python emit_log_direct.py error "Run. Run. Or it will explode."

참고

http://www.rabbitmq.com/tutorials/tutorial-four-python.html