Code samples for next tutorial.

Author: majek

python/emit_log_direct.py

@@ -0,0 +1,19 @@
+#!/usr/bin/env python
+import pika
+import sys
+
+connection = pika.AsyncoreConnection(pika.ConnectionParameters(
+ host='127.0.0.1',
+ credentials=pika.PlainCredentials('guest', 'guest')))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='direct_logs',
+ type='direct')
+
+severity = sys.argv[1] if len(sys.argv) > 1 else 'info'
+assert severity in ('info', 'warning', 'error')
+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)

python/receive_logs_direct.py

@@ -0,0 +1,36 @@
+#!/usr/bin/env python
+import pika
+import sys
+
+connection = pika.AsyncoreConnection(pika.ConnectionParameters(
+ host='127.0.0.1',
+ credentials=pika.PlainCredentials('guest', 'guest')))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='direct_logs',
+ type='direct')
+
+result = channel.queue_declare(auto_delete=True)
+queue_name = result.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:
+ assert severity in ('info', 'warning', 'error')
+ 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, header, body):
+ print " [x] %r:%r" % (method.routing_key, body,)
+
+channel.basic_consume(callback,
+ queue=queue_name,
+ no_ack=True)
+
+pika.asyncore_loop()