airflow.providers.yandex.operators.yq¶

类¶

YQExecuteQueryOperator

使用 Yandex Query 服务执行 SQL 代码。

模块内容¶

class airflow.providers.yandex.operators.yq.YQExecuteQueryOperator(*, name=None, folder_id=None, yandex_conn_id=None, public_ssh_key=None, service_account_id=None, sql, **kwargs)[source]¶

基类: airflow.models.BaseOperator

使用 Yandex Query 服务执行 SQL 代码。

参数:

sql (str) – 作为单个字符串执行的 SQL 代码
name (str | None) – 在 YandexQuery 中的查询名称
folder_id (str | None) – 用于创建查询的云文件夹 ID
yandex_conn_id (str | None) – 用于获取参数的 Airflow 连接 ID

operator_extra_links[source]¶

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

template_fields_renderers[source]¶

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

ui_color = '#ededed'[source]¶

name = None[source]¶

folder_id = None[source]¶

yandex_conn_id = None[source]¶

public_ssh_key = None[source]¶

service_account_id = None[source]¶

sql[source]¶

query_id: str | None = None[source]¶

property hook: airflow.providers.yandex.hooks.yq.YQHook[source]¶

获取有效的 hook。

execute(context)[source]¶

创建操作符时派生。

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

参考 get_template_context 获取更多上下文信息。

on_kill()[source]¶

重写此方法以在任务实例被杀死时清理子进程。

操作符内任何对 threading、subprocess 或 multiprocessing 模块的使用都需要清理，否则会留下僵尸进程。