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

了解 Step Functions 中的活動

透過 Step Functions 活動，您可以在狀態機器中設定任務，其中實際工作是由在 Step Functions 外部執行的工作者執行。例如，您可以在 Amazon Elastic Compute Cloud (Amazon EC2)、Amazon Elastic Container Service (Amazon ECS) 甚至行動裝置上執行工作者程式。

概觀

在 中 AWS Step Functions，活動是將執行某處 （稱為活動工作者) 的程式碼與狀態機器中的特定任務建立關聯的一種方式。您可以使用 Step Functions 主控台或呼叫 來建立活動CreateActivity。這為您的任務狀態提供 Amazon Resource Name (ARN)。使用此 ARN 來輪詢任務狀態，以便在您的活動工作者中使用。

活動工作者可以是在 Amazon EC2 執行個體、 AWS Lambda 函數、行動裝置上執行的應用程式：任何可以進行 HTTP 連線的應用程式，在任何地方託管。當 Step Functions 達到活動任務狀態時，工作流程會等待活動工作者輪詢任務。活動工作者會使用 輪詢 Step FunctionsGetActivityTask，並傳送相關活動的 ARN。 GetActivityTask會傳回包含 input（任務的 JSON 輸入字串） 和 taskToken（任務的唯一識別符） 的回應。在活動工作者完成其工作之後，就可以使用 SendTaskSuccess 或 SendTaskFailure 來提供成功或失敗的報告。這兩個呼叫會使用 GetActivityTask 所提供的 taskToken，將結果與該任務建立關聯。

活動任務的相關 API

Step Functions 提供 APIs用於建立和列出活動、請求任務，以及根據您的工作者結果管理狀態機器的流程。

以下是與活動相關的 Step Functions APIs：

等待活動任務完成

在任務定義中設定 TimeoutSeconds，以設定狀態等待的時間長度。若要讓任務保持作用中並且等待，請在 TimeoutSeconds 中設定的時間內使用 SendTaskHeartbeat，定期從您的活動工作者傳送活動訊號。透過設定長逾時持續時間並主動傳送活動訊號，Step Functions 中的活動最多可以等待一年才能完成執行。

例如，如果您需要一個可等待冗長程序結果的工作流程，請執行下列動作：

執行會暫停於活動任務狀態，並等待活動工作者輪詢任務。將 taskToken 提供給活動工作者後，工作流程就會等待 SendTaskSuccess 或 SendTaskFailure 提供狀態。

如果在 TimeoutSeconds 中設定的時間前，執行並未收到這些資訊或 SendTaskHeartbeat 呼叫，則執行會失敗且執行歷史記錄中會包含 ExecutionTimedOut 事件。任務逾時後，Step Functions 會將任務字符失效。使用過期任務字符的 API 呼叫會失敗，但有TaskTimedOut例外。您的工作者應該處理此錯誤，然後繼續正常操作，例如輪詢GetActivityTask更多工作或關閉。

範例：Ruby 中的活動工作者

下列範例活動工作者程式碼實作消費者生產者模式，其中包含可設定的輪詢器和活動工作者執行緒數量。輪詢器執行緒會持續長時間輪詢 Step Functions 中的活動任務。擷取活動任務時，會通過限制的封鎖佇列，以便擷取活動執行緒。

下列程式碼是此範例 Ruby 活動工作者的主要進入點。

require_relative '../lib/step_functions/activity'
    credentials = Aws::SharedCredentials.new
    region = 'us-west-2'
    activity_arn = 'ACTIVITY_ARN'

    activity = StepFunctions::Activity.new(
      credentials: credentials,
      region: region,
      activity_arn: activity_arn,
      workers_count: 1,
      pollers_count: 1,
      heartbeat_delay: 30
    )

    # Start method block contains your custom implementation to process the input 
    activity.start do |input|
      { result: :SUCCESS, echo: input['value'] }                    
    end

您必須指定活動 ARN 和區域。此程式碼包含您可以設定的預設值，例如執行緒和活動訊號延遲的數量。

後續步驟

如要詳細了解建立使用活動工作者的狀態機器，請參閱：