Create connectors/hubspot_connector.py

connectors/connectors/hubspot_connector.py

@@ -0,0 +1,12 @@
+import os, json
+from cdata.hubspot import connect          # pip install cdata-hubspot
+
+_conn = connect(PrivateAppToken=os.getenv("HUBSPOT_TOKEN"))
+
+def hs_query(sql: str) -> str:
+    """Run SQL against HubSpot objects (Contacts, Deals, etc.)."""
+    cur = _conn.cursor()
+    cur.execute(sql)
+    cols = [d[0] for d in cur.description]
+    rows = [dict(zip(cols, r)) for r in cur.fetchall()]
+    return json.dumps(rows)