Apache Trino 連線

Apache Trino 連線類型允許連線到 Trino,Trino 是一個分散式 SQL 查詢引擎,旨在查詢分佈在一個或多個異質資料來源上的大型資料集。

預設連線 ID

Trino Hook 使用參數 trino_conn_id 作為連線 ID,預設情況下參數值為 trino_default。Trino Hook 支援多種身份驗證類型,以確保系統的所有使用者都經過身份驗證,可以設定參數 auth 以啟用身份驗證。預設情況下,參數值為 None

設定連線

主機

要連線的主機,可以是 localyarn 或 URL。

埠號

如果主機是 URL,請指定埠號。

登入

連線的有效使用者。

密碼

可以用於啟用基本身份驗證。這是一個可選參數,如果使用不同的身份驗證機制,則不需要此參數。

額外參數 (可選,連線參數)

指定可用於 Trino 連線的額外參數 (以 json 字典形式)。支援以下標準 python 參數之外的參數

  • auth - 指定需要啟用的身份驗證類型。值可以是 certskerberosjwt

  • 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__filejwt__token,則 jwt__file 將優先。

此條目是否有幫助?