Как реализовать асинхронную функцию с asyncio в моем случае?

Question

[freakssha]

Цель - создать документ не после закрытия программы, как это происходит сейчас, а во время ее работы.

Функция "first" просто должна вызывать асинхронную "second", которая создаст docx.

def first(self, event):
    loop = asyncio.get_event_loop()
    loop.run(self.second())

async def second(self):
    document = Document()
    document.save('test.docx')

Уверен, проблема в функции «first», в том, как она вызывает «second».

Я работаю над старым проектом, исправлять который нет времени; внутри много ошибок в базовых вещах, поэтому браузер не помог - нужно что-то конкретно под ситуацию. Даже не смотря на это, подскажите, пожалуйста, как решить проблему.
Спасибо.

Comments

[longclaps]

ферст

[Сергей Горностаев]

В приведённом вами коде first вообще не вызывает second.

[freakssha]

Сергей Горностаев, спасибо, не заметил опечатку сразу. теперь реализовать задумку реально?

def first(self, event):
    loop = asyncio.get_event_loop()
    loop.run(self.second())

async def second(self):
    document = Document()
    document.save('test.docx')

[Сергей Горностаев]

daniiyang, document.save('test.docx') - это точно блокирующий вызов. Соответственно, никакой выгоды от вызове его в асинхронной функции вы не получаете, наоборот останавливаете цикл событий.

[freakssha]

Сергей Горностаев, принялся изучать блокирующие вызовы и нашел один вариант решения с помощью подключения дополнительного модуля multiprocessing и concurrent.futures, но это не помогло:

def first(self, event):
    pool = ThreadPoolExecutor(max_workers=multiprocessing.cpu_count())
    loop = asyncio.get_event_loop()
    loop.run_in_executor(pool, second)

Компилируется без ошибок, но docx до сих пор создается только после прерывания процесса выполнения программы.

upd: Имели ли вы ввиду, что асинхронный код в моем случае нельзя получить в принципе? Может, мне стоит применить иной подход?

[Сергей Горностаев]

daniiyang, использование run_in_executor - правильное решение, только её лучше перенести в second и можно явно не задавать пул, но это всё стилистические мелочи. То что файл не создаётся до закрытия программы - явно вина не асинхронности. И если мне не изменяет память, на Тостере уже был вопрос по такой проблеме год или два назад.

Answer 1

[Ihor Peresunko]

Почему конкретно не получается? Есть ошибки?
Вынесете запуск цикла из функции. Вот рабочий пример.

import asyncio


class Document:
    async def save(self, name):
        await asyncio.sleep(1)
        print(f'Document "{name}" has saved')


async def first():
    name = "test_document.doc"
    print("Run first function")
    await second(name)


async def second(name):
    await Document().save(name)


asyncio.run(first())

Из функции first можно асинхронно сохранять как один документ, так и несколько (через await asyncio.gather).

async def first():
    print("Run first function")
    await asyncio.gather(
        second('doc_1'),
        second('doc_2'),
        second('doc_3'),
    )

Из кода не понятна реализация класса Document, но я бы посоветовал сохранение тоже делать не блокирующим. Например можно использовать aiofile для асинхронного сохранения документов на диск.