for i in range(100000):
    lMessage = amqp.Message(
        '~130 bytes of test data..........................................................................................................'
        )
lMessage.properties['delivery_mode'] = 2
lChannel.basic_publish(lMessage, exchange=Exchange)
lChannel.close()
lConnection.close()
Использование сельдерея для обработки огромных текстовых файлов