py-amqp examples

pyamqp_example.py

# Created these after looking at unit tests. Couldn't really find any other online examples. 
from io import BytesIO

from amqp import Connection
import pprint
import pickle

connection = Connection()
channel = connection.channel()
message = channel.basic_get(queue='gegroby/ma.model.cycle.finalcal/analytics_finalcal/')
# channel.basic_ack(message.delivery_tag) acknowledge. otherwise, the same message will keep getting fetched at every attempt. 
result = pickle.load(BytesIO(message.body))
pprint.pprint(result)