Apache Trino 連線¶
Apache Trino 連線類型允許連線到 Trino,Trino 是一個分散式 SQL 查詢引擎,旨在查詢分佈在一個或多個異質資料來源上的大型資料集。
預設連線 ID¶
Trino Hook 使用參數 trino_conn_id
作為連線 ID,預設情況下參數值為 trino_default
。Trino Hook 支援多種身份驗證類型,以確保系統的所有使用者都經過身份驗證,可以設定參數 auth
以啟用身份驗證。預設情況下,參數值為 None
。
設定連線¶
- 主機
要連線的主機,可以是
local
、yarn
或 URL。- 埠號
如果主機是 URL,請指定埠號。
- 登入
連線的有效使用者。
- 密碼
可以用於啟用基本身份驗證。這是一個可選參數,如果使用不同的身份驗證機制,則不需要此參數。
- 額外參數 (可選,連線參數)
指定可用於 Trino 連線的額外參數 (以 json 字典形式)。支援以下標準 python 參數之外的參數
auth
- 指定需要啟用的身份驗證類型。值可以是certs
、kerberos
或jwt
impersonate_as_owner
- 布林值,允許將AIRFLOW_CTX_DAG_OWNER
設定為連線的使用者。
以下額外參數可用於設定身份驗證
jwt__token
- 如果應使用 jwt 身份驗證,則 token 的值由此參數給定。jwt__file
- 如果應使用 jwt 身份驗證,則包含 jwt token 的檔案在磁碟上的位置。certs__client_cert_path
,certs__client_key_path
- 如果應使用憑證身份驗證,則用戶端憑證和金鑰的路徑由此參數給定。kerberos__service_name
,kerberos__config
,kerberos__mutual_authentication
,kerberos__force_preemptive
,kerberos__hostname_override
,kerberos__sanitize_mutual_error_response
,kerberos__principal
,kerberos__delegate
,kerberos__ca_bundle
- 啟用kerberos
身份驗證時,可以設定這些參數。session_properties
- JSON 字典,允許設定 session_properties。範例:{'session_properties':{'scale_writers':true,'task_writer_count:1'}}
client_tags
- 以逗號分隔的標籤列表。範例{'client_tags':['sales','cluster1']}`
timezone
- 可以使用 IANA 時區名稱顯式設定會話的時區。範例:{'timezone':'Asia/Jerusalem'}
。
注意:如果同時給定
jwt__file
和jwt__token
,則jwt__file
將優先。