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 令牌的生命周期（timedelta 格式）

  • token_renewal_delta (datetime.timedelta) – JWT 令牌的续订时间（timedelta 格式）

serialize()[source]

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

async run()[source]

等待 Snowflake 查询完成。

async get_query_status(query_id)[source]

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

此条目是否有帮助？