airflow.providers.ydb.operators.ydb¶

类¶

YDBExecuteQueryOperator

在特定的 YDB 数据库中执行 SQL 代码。

模块内容¶

class airflow.providers.ydb.operators.ydb.YDBExecuteQueryOperator(sql, is_ddl=False, ydb_conn_id='ydb_default', parameters=None, **kwargs)[source]¶

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

在特定的 YDB 数据库中执行 SQL 代码。

参数:

sql (str | list[str]) – 要执行的 SQL 代码，可以是单个字符串，或字符串列表（SQL 语句），或模板文件的引用。以 ‘.sql’ 结尾的字符串被识别为模板引用。
ydb_conn_id (str) – 指向特定 YDB 集群和数据库的 ydb conn id 引用。
parameters (collections.abc.Mapping | collections.abc.Iterable | None) – （可选）用于渲染 SQL 查询的参数。

ui_color = '#ededed'[source]¶