FilesExpand file tree

 master

/

consumer.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

26 lines (20 loc) · 799 Bytes

 master

/

consumer.py

Top

File metadata and controls

• Code
• Blame

26 lines (20 loc) · 799 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

import pika

import json

import config as cfg

# Connect to RabbitMQ and create channel

connection = pika.BlockingConnection(pika.ConnectionParameters(host=cfg.RABBIT_HOST))

channel = connection.channel()

# Declare and listen queue

channel.queue_declare(queue=cfg.QUEUE_TOPIC)

print(' [*] Waiting for messages. To exit press CTRL+C')

# Function process and print data

def callback(ch, method, properties, body):

print("Method: {}".format(method))

print("Properties: {}".format(properties))

data = json.loads(body)

print("ID: {}".format(data['id']))

print("Name: {}".format(data['name']))

print('Description: {}'.format(data['description']))

# Listen and receive data from queue

channel.basic_consume(callback, queue=cfg.QUEUE_TOPIC,no_ack=True)

channel.start_consuming()