Module Contents



Moves data from Oracle to Oracle.

class*, 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.

  • 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 (Optional[dict]) -- 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]
ui_color = #e08c8c[source]
execute(self, context)[source]

This is the main method to 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?