airflow.providers.snowflake.triggers.snowflake_trigger¶

类¶

SnowflakeSqlApiTrigger

获取传入查询 ID 的状态。

模块内容¶

class airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger(poll_interval, query_ids, snowflake_conn_id, token_life_time, token_renewal_delta)[source]¶

基类: airflow.triggers.base.BaseTrigger

获取传入查询 ID 的状态。

参数:

poll_interval (float) – 轮询检查状态的周期（秒）
query_ids (list[str]) – 要运行并轮询状态的查询 ID 列表
snowflake_conn_id (str) – Snowflake 连接 ID 的引用
token_life_time (datetime.timedelta) – JWT Token 的生命周期（以 timedelta 计时）
token_renewal_delta (datetime.timedelta) – JWT Token 的续订时间（以 timedelta 计时）

poll_interval[source]¶

query_ids[source]¶

snowflake_conn_id[source]¶

token_life_time[source]¶

token_renewal_delta[source]¶

serialize()[source]¶

序列化 SnowflakeSqlApiTrigger 的参数和类路径。

async run()[source]¶

等待 Snowflake 查询完成。

async get_query_status(query_id)[source]¶

如果 SQL 查询仍在运行，则返回 True，否则返回 False。