tests.system.teradata.example_teradata_to_teradata_transfer
示例 Airflow DAG,展示 Teradata 到 Teradata 传输操作符的用法。
该传输操作符连接到源 Teradata 服务器,运行查询从源获取数据,并将这些数据插入到目标 Teradata 数据库服务器中。它假设表已经存在。下面的示例 DAG 假设名为 teradata_default 的 Airflow 连接已经存在。它在源和目标上创建示例 my_users 表,在源上设置示例数据,然后运行传输操作符将数据复制到目标服务器上的对应表。
模块内容
-
tests.system.teradata.example_teradata_to_teradata_transfer.ENV_ID[源]
-
tests.system.teradata.example_teradata_to_teradata_transfer.DAG_ID = 'example_teradata_to_teradata_transfer_operator'[源]
-
tests.system.teradata.example_teradata_to_teradata_transfer.CONN_ID = 'teradata_default'[源]
-
tests.system.teradata.example_teradata_to_teradata_transfer.create_src_table[源]
-
tests.system.teradata.example_teradata_to_teradata_transfer.test_run[源]