async def receive(self, text_data):
text_data_json = json.loads(text_data)
self.executer.func.execute(text_data_json['command'])
async for message in self.executer.func.gen:
print(message) # выводит сообщения
await self.send(text_data=json.dumps({
'message': str(message)
}))
хых, у меня 16 Гб, проблем не заметил). код, который с нампи на 3+ млн строк у меня обработался секунд за 15 (но там было мало уникальных строк)
если это единоразовая операция - можете мне скинуть исходный файл, я вам результат верну)