sqlalchemy_trino_engine_quickstart_query_nodes.py

1from sqlalchemy import create_engine
2# For SQLAlchemy 2.0+ use the 'text' construct for SQL strings
3from sqlalchemy.sql import text
4
5# Connection string format: trino://<user>@<host>:<port>/<catalog>/<schema>
6engine = create_engine('trino://user@localhost:8080/system/runtime')
7
8with engine.connect() as connection:
9    # Querying the 'nodes' table in the 'runtime' schema of the 'system' catalog
10    rows = connection.execute(text("SELECT node_id, http_uri FROM nodes")).fetchall()
11    for row in rows:
12        print(f"Node ID: {row[0]}, URI: {row[1]}")