tests.system.providers.teradata.example_teradata_to_teradata_transfer

Example Airflow DAG to show usage of teradata to teradata transfer operator

The transfer operator connects to source teradata server, runs query to fetch data from source and inserts that data into destination teradata database server. It assumes tables already exists. The example DAG below assumes Airflow Connection with connection id teradata_default already exists. It creates sample my_users table at source and destination, sets up sample data at source and then runs transfer operator to copy data to corresponding table on destination server.

Module Contents

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

Was this entry helpful?