airflow.providers.google.cloud.transfers.trino_to_gcs

类

TrinoToGCSOperator

将数据从 TrinoDB 复制到 Google Cloud Storage，支持 JSON、CSV 或 Parquet 格式。

模块内容

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

Bases: airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

将数据从 TrinoDB 复制到 Google Cloud Storage，支持 JSON、CSV 或 Parquet 格式。

参数:

trino_conn_id (str) – 对特定 Trino Hook 的引用。

ui_color = '#a0e08c'[source]
type_map[source]
trino_conn_id = 'trino_default'[source]
属性 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]

此条目是否有帮助？