kombu_amqp_producer_consumer_with_exchange_and_queue.py

1from kombu import Connection, Exchange, Queue
2
3media_exchange = Exchange('media', type='direct')
4video_queue = Queue('video', media_exchange, routing_key='video')
5
6def process_media(body, message):
7    print(body)
8    message.ack()
9
10# connections
11with Connection('amqp://guest:guest@localhost//') as conn:
12
13    # produce
14    producer = conn.Producer(serializer='json')
15    producer.publish({'name': '/tmp/lol.mp4', 'size': 1301013},
16                      exchange=media_exchange, routing_key='video',
17                      declare=[video_queue])
18
19    # consume
20    with conn.Consumer(video_queue, callbacks=[process_media]) as consumer:
21        conn.drain_events()