airflow.providers.teradata.transfers.teradata_to_teradata

Module Contents

Classes

TeradataToTeradataOperator

Moves data from Teradata source database to Teradata destination database.
class airflow.providers.teradata.transfers.teradata_to_teradata.TeradataToTeradataOperator(*, dest_teradata_conn_id, destination_table, source_teradata_conn_id, sql, sql_params=None, rows_chunk=5000, **kwargs)[source]

Bases: airflow.models.BaseOperator

Moves data from Teradata source database to Teradata destination database.

See also

For more information on how to use this operator, take a look at the guide: TeradataToTeradataOperator

Parameters

  • dest_teradata_conn_id (str) – destination Teradata connection.

  • destination_table (str) – destination table to insert rows.

  • source_teradata_conn_id (str) – Source Teradata connection.

  • sql (str) – SQL query to execute against the source Teradata database

  • sql_params (dict | None) – Parameters to use in sql query.

  • rows_chunk (int) – number of rows per chunk to commit.

template_fields: collections.abc.Sequence[str] = ('sql', 'sql_params')[source]
template_ext: collections.abc.Sequence[str] = ('.sql',)[source]
template_fields_renderers[source]
ui_color = '#e07c24'[source]
src_hook()[source]
dest_hook()[source]
execute(context)[source]

Derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?