🐥
Python을 통해 trino 접속 본문
from trino.dbapi import connect
from trino.auth import BasicAuthentication
PORT = my_trino_port
CATALOG = "my_trino_catalog"
HOST = "my_trino_host"
SCHEMA = "my_trino_database"
conn = connect(
user="my_trino_username",
port=PORT,
host=HOST,
catalog=CATALOG,
schema=SCHEMA,
auth=BasicAuthentication("my_trino_username", "my_trino_password"),
http_scheme="https",
verify = False
)
cur=conn.cursor()
cur.execute("select * \
from test_table")
rows = cur.fetchall()
'데이터' 카테고리의 다른 글
[Airflow] Telegram 알림 operator 만들기 (requests 사용) (0) | 2024.03.29 |
---|---|
[Kafka] kafka produce 하기 (with C) (0) | 2023.08.31 |
TRINO -> Hive metastore 사용 시 HIVE_METASTORE_ERROR 오류 조치 (0) | 2023.04.21 |
parquet 파일 구조 (0) | 2022.11.09 |
Least Square / Ridge Regression, RMSE (0) | 2018.10.07 |