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