airflow.providers.amazon.aws.hooks.step_function

類

StepFunctionHook

與 AWS Step Functions State Machine 進行互動。

模組內容

class airflow.providers.amazon.aws.hooks.step_function.StepFunctionHook(*args, **kwargs)[原始碼]

基類: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

與 AWS Step Functions State Machine 進行互動。

提供 boto3.client("stepfunctions") 的輕量級封裝。

可以指定額外的引數（例如 aws_conn_id），這些引數將傳遞給底層的 AwsBaseHook。

另請參閱

start_execution(state_machine_arn, name=None, state_machine_input=None, is_redrive_execution=False)[原始碼]

啟動 State Machine 的執行。

另請參閱

引數:

  • state_machine_arn (str) – AWS Step Function State Machine ARN。

  • is_redrive_execution (bool) – 重新啟動在過去 14 天內未成功完成的 Standard 工作流中失敗的執行。

  • name (str | None) – 執行的名稱。

  • state_machine_input (dict | str | None) – 要傳遞給 State Machine 的 JSON 資料輸入。

返回:

執行 ARN。

返回型別:

str

describe_execution(execution_arn)[原始碼]

描述 State Machine 的執行。

另請參閱

引數:

execution_arn (str) – State Machine 執行的 ARN。

返回:

包含執行詳情的 Dict。

返回型別:

dict

此條目是否有幫助？