tests.system.teradata.example_remote_tpt

Example Airflow DAG to show usage of DdlOperator and TdLoadOperator with remote SSH execution.

This DAG assumes Airflow Connections with connection ids teradata_default and ssh_default already exist locally. It demonstrates how to use DdlOperator and TdLoadOperator to perform remote Teradata operations via SSH, including creating, dropping, altering tables and transferring data.

Attributes

ENV_ID

DAG_ID

CONN_ID

SSH_CONN_ID

SYSTEM_TESTS_DIR

SOURCE_FILE

TARGET_FILE

params

drop_table

test_run

Module Contents

tests.system.teradata.example_remote_tpt.ENV_ID[source]
tests.system.teradata.example_remote_tpt.DAG_ID = 'example_remote_tpt'[source]
tests.system.teradata.example_remote_tpt.CONN_ID = 'teradata_default'[source]
tests.system.teradata.example_remote_tpt.SSH_CONN_ID = 'ssh_default'[source]
tests.system.teradata.example_remote_tpt.SYSTEM_TESTS_DIR = b'.'[source]
tests.system.teradata.example_remote_tpt.SOURCE_FILE[source]
tests.system.teradata.example_remote_tpt.TARGET_FILE[source]
tests.system.teradata.example_remote_tpt.params[source]
tests.system.teradata.example_remote_tpt.drop_table[source]
tests.system.teradata.example_remote_tpt.test_run[source]

Was this entry helpful?