connect to postgres database using asyncpg

connect_db_using_asyncpg.py

import asyncpg

db_config = {
    'user': 'postgres',  # name of db user
    'password': 'my db password',  # db password
    'database': 'my_db',  # database name
    'host': 'localhost'  # or remote db ip address
}

async def custom_query(query_string):
    conn = await asyncpg.connect(**db_config)
    values = await conn.fetch('''{}'''.format(query_string))
    await conn.close()
    return values
    
# to execute a query, custom_query("select * from my_table")
# where my_table is the name of the table