tests.system.teradata.example_s3_to_teradata_transfer

範例 Airflow DAG，展示 S3StorageToTeradataOperator 的用法。

傳輸運算子將 CSV、JSON 和 PARQUET 格式的檔案從 S3 移動到 Teradata 資料表。在下面的範例有向無環圖 (DAG) 中，它假設 ID 為 teradata_default 和 aws_default 的 Airflow 連線已存在。DAG 使用來自 S3 的資料建立資料表，報告插入到資料表中的列數，然後刪除該資料表。

模組內容

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]

這篇文章是否有幫助？