Многопоточные соединения в AIO mysql python - PullRequest
Новая
       25

Многопоточные соединения в AIO mysql python

0 голосов
/ 09 января 2020

У меня ошибка типа:

Ошибка типа: требуется asyncio.Future, сопрограмма или ожидаемое

Как использовать ensure_future и можно ли использовать это? 

async def dowork(loop, output):
    pool = (await aiomysql.create_pool(
        host='127.0.0.1',
        port=3306,
        user='root',
        password='password',
        db='test',
        loop=loop,
        charset='utf8',
        autocommit=True
    ))
    q = ("""blah blah blah""")
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            print(q)
            print()
            await cur.execute(q)
            await conn.commit()
    pool.close()
    await pool.wait_closed()


async def dothis(output):
    loop = asyncio.get_event_loop()
    await loop.run_until_complete(await dowork(loop, output=output))

Из основного модуля звоню: 

asyncio.ensure_future(db.dothis(output))
...