How to understand and use asyncio in Python using PostgreSQL?

Question

I trying to learn how to use the asyncio framework in Python. I have the below code but it is giving the error:

event loop stopped before the future completed.

Also please update where to capture the outputs of the code.

Code:

import asyncio
import aiopg

dsn = 'dbname=dvdrental user=postgres password=password host=127.0.0.1'


async def go():
    pool = await aiopg.create_pool(dsn)
    async with pool.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute("Select * from actor")
            ret = []
            async for row in cur:
                ret.append(row)
            assert ret == [(1,)]

loop = asyncio.get_event_loop()
loop.run_until_complete(go())

What did you find when you searched for that error?

jpmc26
– jpmc26

2018-02-08 02:56:47 +00:00
Commented Feb 8, 2018 at 2:56 — jpmc26
– jpmc26, Commented Feb 8, 2018 at 2:56

Andrew Svetlov · Accepted Answer · 2018-02-08 08:57:47Z

2

The pool is not closed before exit from go() coroutine and loop stopping.

Use async with aiopg.create_pool() instead of await aiopg.create_pool() or explicitly call pool.close()/await pool.await_closed() at the end of coroutine.

answered Feb 8, 2018 at 8:57

Andrew Svetlov

17.5k8 gold badges70 silver badges72 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to understand and use asyncio in Python using PostgreSQL?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related