#!/usr/bin/env python3 import pika # https://www.rabbitmq.com/tutorials/tutorial-one-python.html connection = pika.BlockingConnection(pika.ConnectionParameters('rabbitmq')) channel = connection.channel() channel.queue_declare(queue='hello') connection.close()