airflow.providers.google.cloud.transfers.presto_to_gcs

模組內容

類別

PrestoToGCSOperator

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

class airflow.providers.google.cloud.transfers.presto_to_gcs.PrestoToGCSOperator(*, presto_conn_id='presto_default', **kwargs)[原始碼]

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

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

參數

presto_conn_id (str) – 參考特定的 Presto hook。

ui_color = '#a0e08c'[原始碼]
type_map[原始碼]
query()[原始碼]

查詢 presto 並傳回結果的游標。

field_to_bigquery(field)[原始碼]

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

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

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

參數
  • value – Presto 欄位值

  • schema_type – BigQuery 資料類型

這個條目是否有幫助?