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]

此条目有帮助吗?