from cdata.salesforce import connect  # pip install cdata-salesforce
import os
_conn = connect(User=os.getenv("SF_USER"),
                Password=os.getenv("SF_PASS"),
                SecurityToken=os.getenv("SF_TOKEN"))

def sf_query(s: str):
    cur = _conn.cursor()
    cur.execute(s)
    cols = [d[0] for d in cur.description]
    return [dict(zip(cols, r)) for r in cur.fetchall()]