Function execute_sql

compat/src/test/python/runner_parquet.py:96–103

Execute SQL query via QuestDB HTTP API.

(host: str, port: int, sql: str)

def execute_sql(host: str, port: int, sql: str) -> dict:
    """Execute SQL query via QuestDB HTTP API."""
    url = f"http://{host}:{port}/exec"
    params = {"query": sql}
    response = requests.get(url, params=params, timeout=120)
    if not response.ok:
        raise RuntimeError(f"SQL failed: {response.text}")
    return response.json()


def export_parquet(host: str, port: int, query: str, output_path: str) -> None: