airflow.providers.oracle.transfers.oracle_to_oracle¶

类¶

OracleToOracleOperator

将数据从一个 Oracle 移动到另一个 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]¶

基础： airflow.models.BaseOperator

将数据从一个 Oracle 移动到另一个 Oracle。

参数：

oracle_destination_conn_id (str) – 目标 Oracle 连接。
destination_table (str) – 插入行的目标表。
oracle_source_conn_id (str) – 源 Oracle 连接。
source_sql (str) – 针对源 Oracle 数据库执行的 SQL 查询。(模板化)
source_sql_params (dict | None) – 在 SQL 查询中使用的参数。(模板化)
rows_chunk (int) – 每次提交的行数。

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]¶

创建运算符时派生。

Context 是渲染 jinja 模板时使用的相同字典。

有关更多上下文，请参阅 get_template_context。