airflow.providers.common.sql.triggers.sql

类

SQLExecuteQueryTrigger

一个以异步模式执行 SQL 代码的触发器。

模块内容

类 airflow.providers.common.sql.triggers.sql.SQLExecuteQueryTrigger(sql, conn_id, hook_params=None, **kwargs)[source]

基类: airflow.triggers.base.BaseTrigger

一个以异步模式执行 SQL 代码的触发器。

参数:

  • sql (str | list[str]) – 要执行的 SQL 语句 (str) 或要执行的 SQL 语句列表

  • conn_id (str) – 用于连接数据库的连接 ID

  • hook_params (dict | None) – hook 参数

sql[source]
conn_id[source]
hook_params = None[source]
serialize()[source]

序列化 SQLExecuteQueryTrigger 参数和类路径。

get_hook()[source]

返回 DbApiHook。

返回:

此连接的 DbApiHook

返回类型:

airflow.providers.common.sql.hooks.sql.DbApiHook

异步 run()[source]

在异步上下文中运行触发器。

触发器在想要触发事件时应产出一个 Event，并在完成后返回 None。单事件触发器应因此先产出 Event 然后立即返回。

如果它产出 Event，很可能很快就会被恢复，但也可能不会（例如，如果工作负载正在转移到另一个触发器进程，或者多事件触发器被用于单事件任务延迟）。

无论哪种情况，Trigger 类应假定它们将被持久化，并在不再需要时依赖于 cleanup() 方法被调用。

此条目有帮助吗？