tests.system.teradata.example_teradata_to_teradata_transfer

示例 Airflow DAG,展示 Teradata 到 Teradata 传输操作符的用法。

该传输操作符连接到源 Teradata 服务器,运行查询从源获取数据,并将这些数据插入到目标 Teradata 数据库服务器中。它假设表已经存在。下面的示例 DAG 假设名为 teradata_default 的 Airflow 连接已经存在。它在源和目标上创建示例 my_users 表,在源上设置示例数据,然后运行传输操作符将数据复制到目标服务器上的对应表。

属性

ENV_ID

DAG_ID

CONN_ID

create_src_table

test_run

模块内容

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[源]

此条目是否有帮助?