airflow.providers.teradata.transfers.s3_to_teradata¶
模組內容¶
類別¶
從 Amazon S3 將 CSV、JSON 和 Parquet 格式的資料載入到 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)[原始碼]¶
基底類別：
airflow.models.BaseOperator從 Amazon S3 將 CSV、JSON 和 Parquet 格式的資料載入到 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 連線 ID。
teradata_conn_id (str) – 用於連線到 Teradata 的連線 ID Teradata 連線。
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')[原始碼]¶