`airflow.providers.google.cloud.transfers.trino_to_gcs`¶

模組內容¶

類別¶

TrinoToGCSOperator

將資料從 TrinoDB 複製到 Google Cloud Storage，格式為 JSON、CSV 或 Parquet。

class airflow.providers.google.cloud.transfers.trino_to_gcs.TrinoToGCSOperator(*, trino_conn_id='trino_default', **kwargs)[原始碼]¶

基底類別: airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

將資料從 TrinoDB 複製到 Google Cloud Storage，格式為 JSON、CSV 或 Parquet。

參數: trino_conn_id (str) – 參考特定的 Trino hook。

ui_color = '#a0e08c'[原始碼]¶

type_map[原始碼]¶

query()[原始碼]¶: 查詢 Trino 並傳回結果的游標。

field_to_bigquery(field)[原始碼]¶

將 Trino 欄位類型轉換為 BigQuery 欄位類型。

convert_type(value, schema_type, **kwargs)[原始碼]¶

不做任何事。Trino 在傳輸層使用 JSON，因此類型很簡單。

參數

value – Trino 欄位值
schema_type – BigQuery 資料類型

這個條目是否對您有幫助？