It's an example of pika to send messages to rabbitmq

pika-send.py

import pika

# create a connection for rabbitmq using localhost
connection = pika.BlockingConnection(pika.ConnectionParameters(
                'localhost'))
channel = connection.channel() # create a channel

# declare an exchange
channel.exchange_declare(exchange='messages', type='direct')

# a routing is a label for a message
# receiver will decide which message to get according to routing
routings = ['info', 'warning', 'error']

for routing in routings:
    message = '%s message.' % routing
    channel.basic_publish(exchange='messages',
                          routing_key=routing,
                          body=message)
    print message

connection.close()