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。