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

此条目是否有帮助？