airflow.providers.teradata.operators.teradata¶

类¶

`TeradataOperator`	用于在 Teradata 数据库上执行查询的通用 Teradata 操作符。
`TeradataStoredProcedureOperator`	在指定的 Teradata 数据库中执行存储过程。

模块内容¶

class airflow.providers.teradata.operators.teradata.TeradataOperator(teradata_conn_id=TeradataHook.default_conn_name, schema=None, **kwargs)[source]¶

基类: airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator

用于在 Teradata 数据库上执行查询的通用 Teradata 操作符。

使用 Teradata Python SQL Driver 在 Teradata SQL 数据库中执行 SQL 语句

另请参阅

有关如何使用此操作符的更多信息，请参阅指南: TeradataOperator

参数:

sql – 要执行的 SQL 查询，可以是单个字符串或字符串列表（SQL 语句）
teradata_conn_id (str) – 对预定义数据库的引用
autocommit – 如果为 True，则自动提交每个命令。（默认值：False）
parameters – （可选）用于渲染 SQL 查询的参数。
schema (str | None) – 要连接的 Teradata 数据库。

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

template_ext: collections.abc.Sequence[str] =('.sql',)[source]¶

template_fields_renderers: ClassVar[dict][source]¶

ui_color = '#e07c24'[source]¶

conn_id = 'teradata_default'[source]¶

class airflow.providers.teradata.operators.teradata.TeradataStoredProcedureOperator(*, procedure, teradata_conn_id=TeradataHook.default_conn_name, parameters=None, **kwargs)[source]¶

基类: airflow.models.BaseOperator

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

参数:

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

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

ui_color = '#ededed'[source]¶

teradata_conn_id = 'teradata_default'[source]¶

procedure[source]¶

parameters = None[source]¶

execute(context)[source]¶

创建操作符时派生。

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

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