airflow.providers.google.cloud.transfers.trino_to_gcs

類

TrinoToGCSOperator

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

模組內容

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

基類：airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

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

引數：

trino_conn_id (str) – 對特定 Trino hook 的引用。

ui_color = '#a0e08c'[source]
type_map[source]
trino_conn_id = 'trino_default'[source]
property db_hook: airflow.providers.trino.hooks.trino.TrinoHook[source]
query()[source]

查詢 trino 並返回結果的遊標。

field_to_bigquery(field)[source]

將 trino 欄位型別轉換為 BigQuery 欄位型別。

convert_type(value, schema_type, **kwargs)[source]

不執行任何操作。Trino 在傳輸層使用 JSON，因此型別很簡單。

引數：

  • value – Trino 列值

  • schema_type – BigQuery 資料型別

get_openlineage_facets_on_start()[source]

此條目有幫助嗎？