for i in range(100000):
    lMessage = amqp.Message(
        '~130 bytes of test data..........................................................................................................'
        )
Using celery to process huge text files