airflow.providers.oracle.operators.oracle¶

类¶

OracleStoredProcedureOperator

在指定的 Oracle 数据库中执行存储过程。

模块内容¶

class airflow.providers.oracle.operators.oracle.OracleStoredProcedureOperator(*, procedure, oracle_conn_id='oracle_default', parameters=None, **kwargs)[source]¶

基类: airflow.models.BaseOperator

在指定的 Oracle 数据库中执行存储过程。

参数:

procedure (str) – 要调用的存储过程名称（模板化）
oracle_conn_id (str) – 引用特定 Oracle 数据库的Oracle 连接 ID。
parameters (dict | list | None) – （可选，模板化）调用中提供的参数

如果 do_xcom_push 为 True，数据库发出的数字退出码在失败时会以键 ORA 推送到 XCom。

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

ui_color = '#ededed'[source]¶

oracle_conn_id = 'oracle_default'[source]¶

procedure[source]¶

parameters = None[source]¶

execute(context)[source]¶

在创建 operator 时派生。

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

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