airflow.providers.oracle.transfers.oracle_to_oracle¶

Classes¶

OracleToOracleOperator

Moves data from Oracle to Oracle.

Module Contents¶

class airflow.providers.oracle.transfers.oracle_to_oracle.OracleToOracleOperator(*, oracle_destination_conn_id, destination_table, oracle_source_conn_id, source_sql, source_sql_params=None, rows_chunk=5000, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Moves data from Oracle to Oracle.

Parameters:

oracle_destination_conn_id (str) – destination Oracle connection.
destination_table (str) – destination table to insert rows.
oracle_source_conn_id (str) – Source Oracle connection.
source_sql (str) – SQL query to execute against the source Oracle database. (templated)
source_sql_params (dict | None) – Parameters to use in sql query. (templated)
rows_chunk (int) – number of rows per chunk to commit.

template_fields: collections.abc.Sequence[str] = ('source_sql', 'source_sql_params')[source]¶

template_fields_renderers[source]¶

ui_color = '#e08c8c'[source]¶

oracle_destination_conn_id[source]¶

destination_table[source]¶

oracle_source_conn_id[source]¶

source_sql[source]¶

source_sql_params = None[source]¶

rows_chunk = 5000[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.