python - 使用 aiomysql 在 aiohttp 中创建连接池

Question

我需要能够像这样访问 aiohttp 应用程序中的 aiomysql 连接池

async def get(request):
    async with request.app['db'].acquire() as conn:
        async with connection.cursor() as cur:
            await cur.execute('SELECT ...')
            rows = await cur.fetchall()
            return web.json_response(rows)

要将连接池保留在应用程序中，我知道我需要执行类似的操作

app = web.Application()
loop = asyncio.get_event_loop()
app['db'] = aiomysql.create_pool(db='...', user='...', password='...', loop=loop)
app.add_routes(routes)
web.run_app(app)

但是，这显然失败了，因为 aiomysql.create_pool 是一个协程。这里的正确语法是什么？

Answer 1

我知道它很晚，但希望它可以帮助某人，您可以通过以下方式创建池

import aiomysql

async def init_db(app):
    pool = await aiomysql.create_pool(host='host', port=2222),
                                  user='user', password='password',
                                  db='dbname')
app['mysql_db'] = pool

然后你可以使用池来获取连接

    async def someApi(request):
      pool = request.app["mysql_db"]
      async with pool.acquire() as conn:
        async with conn.cursor() as cur:
           await cur.execute("select * from table")
           rows = await cur.fetchall()