Основная программа, которая окружает этот процесс, будет использовать python concurrent.futures для запуска приведенного ниже сценария Python.
run_trino.py (псевдокод)
Код: Выделить всё
import trino
query = "select * from database.table"
conn = trino.dbapi.connect(
host = host,
port = port,
http_scheme = "https",
catalog = "catalog",
verify = False
)
cur = conn.cursor()
cur.execute(query) #