How do I use asyncpg for PostgreSQL in Python?

How do I use asyncpg for PostgreSQL in Python?

To use asyncpg, first install it using pip: pip install asyncpg. Then, you can connect to your PostgreSQL database asynchronously.

Can you show me a simple example of connecting to a database?

Sure! Here's a basic example:

import asyncpg

async def main():
    conn = await asyncpg.connect(user='user', password='password', database='db', host='127.0.0.1')
    await conn.close()

What about executing queries?

You can execute queries using the fetch or execute methods. For example:

rows = await conn.fetch('SELECT * FROM my_table')

Is there a way to handle errors?

Yes, you can use try-except blocks to handle exceptions. For example:

try:
    await conn.execute('INVALID SQL')
except Exception as e:
    print(f'Error: {e}')