airflow.providers.exasol.operators.exasol¶

类¶

ExasolOperator

在指定的 Exasol 数据库中执行 sql 代码。

模块内容¶

class airflow.providers.exasol.operators.exasol.ExasolOperator(*, exasol_conn_id='exasol_default', schema=None, handler=exasol_fetch_all_handler, **kwargs)[源代码]¶

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

在指定的 Exasol 数据库中执行 sql 代码。

参数:

sql – 要执行的 SQL 代码，可以是单个字符串、字符串列表（sql 语句），或者模板文件的引用。模板引用通过以“.sql”结尾的字符串识别。
exasol_conn_id (str) – 指定 Exasol 数据库的引用
autocommit – 如果为 True，每个命令将自动提交。（默认值：False）
parameters – （可选）用于渲染 SQL 查询的参数。
schema (str | None) – （可选）模式名称，将覆盖连接中定义的模式
handler – （可选）用于处理查询结果的处理器

template_fields: collections.abc.Sequence[str] = ('sql', 'exasol_conn_id')[源代码]¶

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

template_fields_renderers: ClassVar[dict][源代码]¶

ui_color = '#ededed'[源代码]¶

conn_id_field = 'exasol_conn_id'[源代码]¶

exasol_conn_id = 'exasol_default'[源代码]¶