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)[源代码]

基类: 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

template_fields: collections.abc.Sequence[str] = ('sql',)[源代码]
template_fields_renderers[源代码]
template_ext: collections.abc.Sequence[str] = ('.sql',)[源代码]
ui_color = '#ededed'[源代码]
hook()[源代码]

获取有效的钩子。

execute(context)[源代码]

在创建操作符时派生。

上下文与渲染 Jinja 模板时使用的字典相同。

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

on_kill()[源代码]

当任务实例被终止时，重写此方法以清理子进程。

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

此条目是否有帮助？