tests.system.teradata.example_teradata_to_teradata_transfer

範例 Airflow DAG 示範 teradata to 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]

此條目是否有幫助?