def callback(channel, method, properties, body):
    print(body)
channel.basic_ack(delivery_tag=method.delivery_tag)

def on_open(connection):
    connection.channel(on_channel_open)

def on_channel_open(channel):
    channel.basic_consume(callback, queue='queue1')
channel.basic_consume(callback, queue='queue2')
parameters = pika.URLParameters('amqp://guest:guest@localhost:5672/%2F')
Consume multiple queues in python / pika