開始一個新的 AWS Step Functions 來自正在運行的執行狀態機 - AWS Step Functions

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

開始一個新的 AWS Step Functions 來自正在運行的執行狀態機

Step Functions 集成了自己API的服務集成。瞭解如何使用 Step Functions 直接從執行中執行的工作狀態開始狀態機器的新執行。在建置新的工作流程時,使用巢狀工作流程執行來降低主要工作流程的複雜性,並重複使用常見的程序。

優化 Step Functions 集成的主要功能

請注意,請求回應使用任務令牌等待回調整合模式沒有最佳化。

如需詳細資訊,請參閱下列內容:

支援的 Step Functions APIs

工作流程範例

以下包含 Task 狀態,此狀態會啟動另一個狀態機器的執行並等待其完成。

{ "Type":"Task", "Resource":"arn:aws:states:::states:startExecution.sync:2", "Parameters":{ "Input":{ "Comment": "Hello world!" }, "StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld", "Name":"ExecutionName" }, "End":true }

以下包含 Task 狀態,此狀態會啟動另一個狀態機器的執行。

{ "Type":"Task", "Resource":"arn:aws:states:::states:startExecution", "Parameters":{ "Input":{ "Comment": "Hello world!" }, "StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld", "Name":"ExecutionName" }, "End":true }

以下包含 Task 狀態,此狀態會實作回呼服務整合模式。

{ "Type":"Task", "Resource":"arn:aws:states:::states:startExecution.waitForTaskToken", "Parameters":{ "Input":{ "Comment": "Hello world!", "token.$": "$$.Task.Token" }, "StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld", "Name":"ExecutionName" }, "End":true }

若要將巢狀工作流程執行與啟動它的父執行建立關聯,請傳遞特別命名的參數,其中包含從內容物件提取的執行 ID。啟動巢狀執行時,請使用名為 AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID 的參數。透過將 .$ 附加至參數名稱,並使用 $$.Execution.Id 參考內容物件中的 ID 來傳遞執行 ID。如需詳細資訊,請參閱存取內容物件

{ "Type":"Task", "Resource":"arn:aws:states:::states:startExecution.sync", "Parameters":{ "Input":{ "Comment": "Hello world!", "AWS_STEP_FUNCTIONS_STARTED_BY_EXECUTION_ID.$": "$$.Execution.Id" }, "StateMachineArn":"arn:aws:states:us-east-1:123456789012:stateMachine:HelloWorld", "Name":"ExecutionName" }, "End":true }

巢狀狀態機器會傳回下列內容:

資源 輸出
startExecution. 同步 字串
startExecution. 同步:2 JSON

兩者都將等待巢狀狀態機器完成,但它們會傳回不同的 Output 格式。例如,如果您建立傳回物件的 Lambda 函數{ "MyKey": "MyValue" },您會得到下列回應:

對於 startExecution .sync:

{ <other fields> "Output": "{ \"MyKey\": \"MyValue\" }" }

對於 startExecution .sync:2:

{ <other fields> "Output": { "MyKey": "MyValue" } }

設定巢狀狀態機器的IAM權限

父狀態機器判斷子狀態機器是否已使用輪詢和事件完成執行。輪詢需要權限,states:DescribeExecution而傳送 EventBridge 至 Step Functions 的事件需要events:PutTargetsevents:PutRule、和的權限events:DescribeRule。如果您的IAM角色中缺少這些權限,則在父狀態機器意識到子狀態機器的執行完成之前,可能會有一段延遲。

對於呼叫StartExecution單一巢狀工作流程執行的狀態機器,請使用限制該狀態機器權限的IAM原則。

如需詳細資訊,請參閱 Step Functions 的IAM權限

IAM呼叫巢狀 Step Functions 工作流程的原則

對於呼叫StartExecution單一巢狀工作流程執行的狀態機器,請使用限制該狀態機器權限的IAM原則。

{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "states:StartExecution" ], "Resource": [ "arn:aws:states:[[region]]:[[accountId]]:stateMachine:[[stateMachineName]]" ] } ] }

如需詳細資訊,請參閱下列內容:

Synchronous
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "states:StartExecution" ], "Resource": [ "arn:aws:states:[[region]]:[[accountId]]:stateMachine:[[stateMachineName]]" ] }, { "Effect": "Allow", "Action": [ "states:DescribeExecution", "states:StopExecution" ], "Resource": [ "arn:aws:states:[[region]]:[[accountId]]:execution:[[stateMachineName]]:*" ] }, { "Effect": "Allow", "Action": [ "events:PutTargets", "events:PutRule", "events:DescribeRule" ], "Resource": [ "arn:aws:events:[[region]]:[[accountId]]:rule/StepFunctionsGetEventsForStepFunctionsExecutionRule" ] } ] }
Asynchronous
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "states:StartExecution" ], "Resource": [ "arn:aws:states:[[region]]:[[accountId]]:stateMachine:[[stateMachineName]]" ] } ] }

如需巢狀工作流程執行的詳細資訊,請參閱從 Step Functions 數中的工作狀態啟動工作流程執行