Path: csiph.com!fu-berlin.de!uni-berlin.de!not-for-mail
From: Ray Cote <rgacote@appropriatesolutions.com>
Newsgroups: comp.lang.python
Subject: Re: Looking for examples of using aiopg with aiohttp and non-async startup.
Date: Fri, 26 Feb 2016 09:52:12 -0500
Lines: 66
Message-ID: <mailman.153.1456498366.20994.python-list@python.org>
References: <CAG5tnzrGFexYKaC6YhMaP-_vwudMgxwGNibh19DWmKLQMqp9vQ@mail.gmail.com>
Mime-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
In-Reply-To: <CAG5tnzrGFexYKaC6YhMaP-_vwudMgxwGNibh19DWmKLQMqp9vQ@mail.gmail.com>
Precedence: list
Xref: csiph.com comp.lang.python:103543

Answer (obvious after a refreshing sleep):
Just run a separate async pool connection prior to kicking off the aiohttp
web application.
The startup now looks like:

async def connect():
    return await aiopg.create_pool(=E2=80=A6)

if __name__ =3D=3D =E2=80=9C__main__=E2=80=9D:
    loop =3D asyncio.get_event_loop()
    pool =3D loop.run_until_complete(connect())
    app =3D web.Application()
    app["pool"] =3D pool
    app.router.add_route(=E2=80=98POST', '/pv/v1/', handle_v1)
    web.run_app(app)


Then, in the handle_v1 code:
    pool =3D request.app["pool"]
    connection =3D await pool.acquire()
    cursor =3D await connection.cursor()
=E2=80=94r

On Thu, Feb 25, 2016 at 5:23 PM, Ray Cote <rgacote@appropriatesolutions.com=
>
wrote:

> Hello:
>
> I have an aiohttp project that starts in the usual way:
>
> app =3D web.Application()
> app.router.add_route(=E2=80=98POST=E2=80=9D, =E2=80=98/=E2=80=98, handler=
)
> web.run_app(app)
>
> My question is, how do I work with an aiopg.pool with aiohttp?
> There only seems to be async interfaces into aiopg =E2=80=94 but I don=E2=
=80=99t want to
> create the pool in my handler since that requires a connection on each
> transaction.
>
> I found one example that was
>   app[=E2=80=9Cdb=E2=80=9D] =3D await aiopg.create_pool(dsn)
> but that doesn=E2=80=99t seen correct since we=E2=80=99re not yet in a lo=
op.
>
> Can someone please provide an example showing the proper way to integrate
> aiopg pool into an aiohttp web application?
>
> Regards
> =E2=80=94Ray
>
> --
> Raymond Cote, President
> voice: +1.603.924.6079 email: rgacote@AppropriateSolutions.com skype:
> ray.cote
>
>
>


--=20
Raymond Cote, President
voice: +1.603.924.6079 email: rgacote@AppropriateSolutions.com skype:
ray.cote