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[原始碼]¶

presto_conn_id = 'presto_default'[原始碼]¶

query()[原始碼]¶: 查詢 Presto 並返回結果的遊標。

field_to_bigquery(field)[原始碼]¶

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

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

什麼也不做。 Presto 在傳輸層使用 JSON，因此型別很簡單。

引數:

value – Presto 列值
schema_type – BigQuery 資料型別

此條目有幫助嗎？