Ответить пользователь и продолжать работать функции асинхронного

Question

Я хочу, чтобы реагировать на пользователь, как только я получил запрос, а затем продолжить, чтобы сохранить данные в базу данных

async def index(request): 
    data = await request.post() 
    response.write("done") 
    async with request.app.mysqlpool.acquire() as conn: 
     async with conn.cursor() as cur: 
      await cur.execute("INSERT INTO ...") 

Если я пытаюсь обернуть часть после запроса. пишите в отдельную функцию и вызывайте ее с помощью run_in_executor - она ​​не позволяет ожидать ожидаемые функции внутри (TypeError: сопрограммы не могут использоваться с run_in_executor())

Есть ли способ сделать это в aiohttp?

Answer 1

Push await response.drain() сразу после response.write(...) call.

Он точно не гарантирует, что данные отправляются через провод, но это самое близкое решение.