FastAPI app with asyncpg minimal example

app.py

import os
import asyncpg
from fastapi import FastAPI

DATABASE_URL = os.getenv("DATABASE_URL")
app = FastAPI()

async def get_db_meta():
    conn = await asyncpg.connect(DATABASE_URL)
    records = await conn.fetch("select nspname from pg_namespace;")
    return records


@app.get("/")
async def read_root():
    db_meta = await get_db_meta()
    names = [record["nspname"] for record in db_meta]
    return {"names": names}