tests.system.teradata.example_s3_to_teradata_transfer
展示 S3StorageToTeradataOperator 用法的 Airflow DAG 示例。
该传输操作符可以将 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]