使用asyncpg构建SQL查询

我有一个这样的功能：

async def fetch(arg1, arg2=None):
    query = "SELECT * FROM table WHERE arg1 = $1"
    args = [arg1]
 
    if arg2 is not None:
        query += " AND arg2 = $2"
        args.append(arg2)

    async with pool.acquire() as conn:
        data = await conn.fetch(query, *args)
    return data

它只是运行一个查询，根据提供给函数的参数，将向查询添加更多的子句。

我不认为这是正确的、漂亮的方法。我的问题是——如何构建SQL查询？