Decode celery data from djkombu_messages table

decode.py

"""
This script excepts a data file to contain a single base64 encoded 
string - which is the payload from djkombu from the djkombu_message table.

"""
import base64
import cPickle as pickle


def decode(line_number):
    with open('data5.txt', 'r') as f:
        for i, line in enumerate(f):
            message = base64.b64decode(line)
            # print pickle.loads(message)
            with open('message_pid.txt', 'wb') as x:
                x.write(message)