listen notifications from postgresql using asyncpg

pg_listener.py

import asyncio
import asyncpg


async def main():
    conn: asyncpg.Connection = await asyncpg.connect()

    def callback(c: asyncpg.Connection, pid: int, ch: str, p: str):
        print(c, pid, ch, p)

    await conn.add_listener("chan", callback)

    await asyncio.sleep(10)
    print("closing connection")
    await conn.close()


if __name__ == "__main__":
    asyncio.run(main())