Asynchronous Quick Start

Most of the API is the same as the synchronous one, but any that communicate with the server require the await keyword.

Connecting

To connect, pass a libpq connection string to the async_connect() function.

import asyncio
import pglib
cnxn = await pglib.connect_async('host=localhost dbname=test')

Selecting

There are asynchronous versions of execute, fetchrow, and fetchval:

rset  = await cnxn.execute("select id, name from users")
row   = await cnxn.fetchrow("select count(\*) as cnt from users")
count = await cnxn.fetchval("select count(\*) from users")

The ResultSet and Row objects don’t require await.