tests.system.teradata.example_s3_to_teradata_transfer

展示 S3StorageToTeradataOperator 用法的 Airflow DAG 示例。

該傳輸運算子可以將 CSV、JSON 和 PARQUET 格式的檔案從 S3 遷移到 Teradata 表中。在下面的有向無環圖(DAG)示例中,假設 ID 為 teradata_defaultaws_default 的 Airflow 連線已存在。該 DAG 使用 S3 中的資料建立表,報告插入表中的行數,然後刪除該表。

屬性

ENV_ID

DAG_ID

CONN_ID

transfer_data_csv

test_run

模組內容

tests.system.teradata.example_s3_to_teradata_transfer.ENV_ID[source]
tests.system.teradata.example_s3_to_teradata_transfer.DAG_ID = 'example_s3_to_teradata_transfer_operator'[source]
tests.system.teradata.example_s3_to_teradata_transfer.CONN_ID ='teradata_default'[source]
tests.system.teradata.example_s3_to_teradata_transfer.transfer_data_csv[source]
tests.system.teradata.example_s3_to_teradata_transfer.test_run[source]

此條目有幫助嗎?