airflow.providers.amazon.aws.sensors.step_function¶

類¶

輪詢 Step Function 狀態機執行直到其達到終止狀態；如果任務失敗則失敗。

class airflow.providers.amazon.aws.sensors.step_function.StepFunctionExecutionSensor(*, execution_arn, **kwargs)[source]¶

輪詢 Step Function 狀態機執行直到其達到終止狀態；如果任務失敗則失敗。

執行成功完成後，Sensor 會將狀態機的輸出透過 XCom Push 到 output

另請參閱

有關如何使用此 Sensor 的更多資訊，請參閱指南：等待 AWS Step Functions 狀態機執行狀態

引數:

execution_arn (str) – 要檢查其狀態的 execution_arn
aws_conn_id – 用於 AWS 憑證的 Airflow 連線。如果此引數為 None 或為空，則使用預設的 boto3 行為。如果以分散式方式執行 Airflow 且 aws_conn_id 為 None 或為空，則將使用預設的 boto3 配置（並且必須在每個 worker 節點上維護）。
region_name – AWS region_name。如果未指定，則使用預設的 boto3 行為。
verify – 是否驗證 SSL 證書。參見： https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客戶端的配置字典（鍵值對）。參見： https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

poke(context)[source]¶

在此類派生時覆蓋。