airflow.providers.teradata.transfers.s3_to_teradata¶

類¶

S3ToTeradataOperator

將 CSV、JSON 和 Parquet 格式資料從 Amazon S3 載入到 Teradata。

模組內容¶

class airflow.providers.teradata.transfers.s3_to_teradata.S3ToTeradataOperator(*, s3_source_key, public_bucket=False, teradata_table, aws_conn_id='aws_default', teradata_conn_id='teradata_default', teradata_authorization_name='', **kwargs)[source]¶

基類: airflow.models.BaseOperator

將 CSV、JSON 和 Parquet 格式資料從 Amazon S3 載入到 Teradata。

另請參閱

有關如何使用此運算子的更多資訊，請參閱以下指南： S3ToTeradataOperator

引數:

s3_source_key (str) – 指定 S3 儲存桶位置的 URI 格式。(模版化) URI 格式為 /s3/YOUR-BUCKET.s3.amazonaws.com/YOUR-BUCKET-NAME。請參閱 https://docs.teradata.com/search/documents?query=native+object+store&sort=last_update&virtual-field=title_only&content-lang=en-US
public_bucket (bool) – 指定所提供的 S3 儲存桶是否為公共儲存桶。如果儲存桶是公共的，則意味著任何人都可以透過 URL 訪問其中的物件而無需身份驗證。如果儲存桶是私有的且未提供身份驗證，則運算子將丟擲異常。
teradata_table (str) – 資料將被傳輸到的 Teradata 表名。(模版化)
aws_conn_id (str) – 用於 AWS 憑據的 Airflow AWS 連線。
teradata_conn_id (str) – 用於連線到 Teradata 的連線 ID。 Teradata connection。
teradata_authorization_name (str) – Teradata 授權資料庫物件的名稱，用於控制誰可以訪問 S3 物件儲存。請參閱 https://docs.teradata.com/r/Enterprise_IntelliFlex_VMware/Teradata-VantageTM-Native-Object-Store-Getting-Started-Guide-17.20/Setting-Up-Access/Controlling-Foreign-Table-Access-with-an-AUTHORIZATION-Object

請注意，s3_source_key 和 teradata_table 是模版化的，因此您可以在其中使用變數。

template_fields: collections.abc.Sequence[str] = ('s3_source_key', 'teradata_table')[source]¶

ui_color = '#e07c24'[source]¶

s3_source_key[source]¶

public_bucket = False[source]¶

teradata_table[source]¶

aws_conn_id = 'aws_default'[source]¶

teradata_conn_id = 'teradata_default'[source]¶

teradata_authorization_name = ''[source]¶

execute(context)[source]¶

建立運算子時派生。

上下文與渲染 jinja 模板時使用的字典相同。

有關更多上下文資訊，請參閱 get_template_context。