magic_duckdb.py

import duckdb

def dquery(
    query_string,
    _single_row_as_dict_=True,
    **dfs_for_query,
):
    con = duckdb.connect(database=':memory:')
    for tbl_name, df in dfs_for_query.items():
        con.register(tbl_name, df)
    
    out = con.execute(query_string).df()
    
    if _single_row_as_dict_ and len(out) == 1:
        out = dict(out.iloc[0])
    
    return out

https://duckdb.org/2021/05/14/sql-on-pandas.html