tests.system.teradata.example_teradata_to_teradata_transfer

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

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

模块内容

tests.system.teradata.example_teradata_to_teradata_transfer.ENV_ID[source]
tests.system.teradata.example_teradata_to_teradata_transfer.DAG_ID = 'example_teradata_to_teradata_transfer_operator'[source]
tests.system.teradata.example_teradata_to_teradata_transfer.CONN_ID = 'teradata_default'[source]
tests.system.teradata.example_teradata_to_teradata_transfer.create_src_table[source]
tests.system.teradata.example_teradata_to_teradata_transfer.test_run[source]

此条目是否对您有帮助?