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 数据类型

此条目有帮助吗？