http post from from queue

gistfile1.py

import pika
import requests
import json

def send_request(data, url): 
  headers = {'content-type': 'application/json'}
  requests.post(url, data=data, headers=headers)  
  print "successfully: " + data

def on_message(channel, method_frame, header_frame, body):
  send_request(body, "http://howhotismyshed.com.au/reading")
  channel.basic_ack(delivery_tag=method_frame.delivery_tag)


connection = pika.BlockingConnection()
channel = connection.channel()
channel.basic_consume(on_message, 'temperatures')
try:
  channel.start_consuming()
except KeyboardInterrupt:
  channel.stop_consuming()
  connection.close()
except:
  exc_type, exc_value, exc_traceback = sys.exc_info()
  print traceback.format_exc()