airflow.providers.amazon.aws.hooks.step_function

模块内容

类

StepFunctionHook

与 AWS Step Functions 状态机交互。
class airflow.providers.amazon.aws.hooks.step_function.StepFunctionHook(*args, **kwargs)[source]

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

与 AWS Step Functions 状态机交互。

提供 boto3.client("stepfunctions") 的精简封装。

可以指定其他参数（例如 aws_conn_id），这些参数将传递到底层的 AwsBaseHook。

另请参阅

start_execution(state_machine_arn, name=None, state_machine_input=None, is_redrive_execution=False)[source]

启动状态机的执行。

另请参阅

参数

  • state_machine_arn (str) – AWS Step Function 状态机 ARN。

  • is_redrive_execution (bool) – 重新启动过去 14 天内未成功完成的标准工作流的不成功执行。

  • name (str | None) – 执行的名称。

  • state_machine_input (dict | str | None) – 要传递给状态机的 JSON 数据输入。

返回

执行 ARN。

返回类型

str

describe_execution(execution_arn)[source]

描述状态机执行。

另请参阅

参数

execution_arn (str) – 状态机执行的 ARN。

返回

包含执行详细信息的字典。

返回类型

dict

此条目是否有帮助？