tests.system.teradata.example_s3_to_teradata_transfer

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

传输操作符将 CSV、JSON 和 PARQUET 格式的文件从 S3 移动到 Teradata 表。在下面的示例有向无环图 (DAG) 中，它假设 Airflow 连接，ID 为 teradata_default 和 aws_default 已经存在。该 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]

这个条目有帮助吗？