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。

此條目是否有幫助？