`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)[源代码]¶

基类：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'[源代码]¶

type_map[源代码]¶

query()[源代码]¶: 查询 Trino 并返回结果的游标。

field_to_bigquery(field)[源代码]¶

将 Trino 字段类型转换为 BigQuery 字段类型。

convert_type(value, schema_type, **kwargs)[源代码]¶

不执行任何操作。Trino 在传输层使用 JSON，因此类型很简单。

参数

value – Trino 列值
schema_type – BigQuery 数据类型

此条目是否有帮助？