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

此條目是否有幫助?