airflow.providers.oracle.transfers.oracle_to_oracle

Module Contents

Classes

OracleToOracleOperator

Moves data from Oracle to Oracle.
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: Sequence[str] = ('source_sql', 'source_sql_params')[source]
template_fields_renderers[source]
ui_color = '#e08c8c'[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?