使用 Lambda 函數在 Step Functions 中繼續新的執行

1. 開啟 Lambda 主控台，然後選擇 Create function (建立函數)。

2. 在 Create function (建立函數) 頁面上，選擇 Author from scratch (從頭開始撰寫)。

3. 在基本資訊區段中，設定 Lambda 函數，如下所示：

   1. 針對 函數名稱 ，請輸入 Iterator。

   2. 針對 執行時間，請選擇 Node.js 16.x。

   3. 保留頁面上的所有預設選擇，然後選擇建立函數 。

      建立 Lambda 函數時，請在頁面右上角記下其 Amazon Resource Name （ARN），例如：

      arn:aws:lambda:us-east-1:123456789012:function:Iterator

4. 將 Lambda 函數的下列程式碼複製到 的程式碼來源區段 Iterator Lambda 主控台中的 頁面。

   exports.handler = function iterator (event, context, callback) {
     let index = event.iterator.index;
     let step = event.iterator.step;
     let count = event.iterator.count;
    
     index = index + step;
    
     callback(null, {
       index,
       step,
       count,
       continue: index < count
     })
   }

   此程式碼接受輸入值為 count、index 和 step。這會將 step 的值增加 index，並傳回這些值及布林值 continue。如果 index 低於 count，則 continue 的值為 true。

5. 選擇部署以部署程式碼。

1. 在設定測試事件對話方塊中，選擇建立新的測試事件 ，然後TestIterator輸入事件名稱 。

2. 將範例資料取代為以下內容。

   {
     "Comment": "Test my Iterator function",
     "iterator": {
       "count": 10,
       "index": 5,
       "step": 1
     }
   }
   

   這些值會模擬反覆運算期間來自狀態機器的內容。Lambda 函數會增加索引，並傳回continue為 true。當索引未低於 count，就會以 false 的形式傳回 continue。對於此測試，索引已經增加到 5。結果應該將 index 增加到 6 和將 continue 設定為 true。

3. 選擇 Create (建立)。

4. 在 上 迭代器 頁面，請確定TestIterator已列出，然後選擇測試 。

   測試結果會顯示在頁面頂端。選擇 Details (詳細資訊) 並檢閱結果。

   {
     "index": 6,
     "step": 1,
     "count": 10,
     "continue": true
   }
   

   注意

   如果您將此測試的 index 設定為 9，則 index 會增加至 10，且 continue 為 false。

1. 開啟 Lambda 主控台，然後選擇 Create function (建立函數)。

2. 在 Create function (建立函數) 頁面上，選擇 Author from scratch (從頭開始撰寫)。

3. 在基本資訊區段中，設定 Lambda 函數，如下所示：

   1. 針對 函數名稱 ，請輸入 Restart。

   2. 針對 執行時間，請選擇 Node.js 16.x。

4. 保留頁面上的所有預設選擇，然後選擇建立函數 。

   建立 Lambda 函數時，請在頁面右上角記下其 Amazon Resource Name （ARN），例如：

   arn:aws:lambda:us-east-1:123456789012:function:Iterator

5. 將 Lambda 函數的下列程式碼複製到 的程式碼來源區段 Restart Lambda 主控台中的 頁面。

   下列程式碼會減少執行數量的計數，並啟動狀態機器的新執行，包括遞減數值。

   var aws = require('aws-sdk');
   var sfn = new aws.StepFunctions();
   
   exports.restart = function(event, context, callback) {
   
     let StateMachineArn = event.restart.StateMachineArn;
     event.restart.executionCount -= 1;
     event = JSON.stringify(event);
   
     let params = {
         input: event,
         stateMachineArn: StateMachineArn
     };
   
     sfn.startExecution(params, function(err, data) {
         if (err) callback(err);
         else callback(null,event);
     });
   
   }

6. 選擇部署以部署程式碼。

建立 狀態機器

1. 開啟 Step Functions 主控台，然後選擇建立狀態機器 。

   重要

   請確定您的狀態機器與您在步驟 1 和步驟 2 中建立的 Lambda 函數位於相同的 AWS 帳戶和區域。

2. 在選擇範本對話方塊中，選取空白 。

3. 選擇選取以在 中開啟 Workflow Studio設計模式。

4. 對於本教學課程，您將在 中寫入狀態機器的 Amazon States Language（ASL） 定義程式碼編輯器。若要執行此操作，請選擇程式碼 。

5. 移除現有的樣板程式碼並貼上下列程式碼。請記得將此程式碼ARNs中的 取代為您建立ARNs的 Lambda 函數的 。

   {
       "Comment": "Continue-as-new State Machine Example",
       "StartAt": "ConfigureCount",
       "States": {
           "ConfigureCount": {
               "Type": "Pass",
               "Result": {
                   "count": 100,
                   "index": -1,
                   "step": 1
               },
               "ResultPath": "$.iterator",
               "Next": "Iterator"
           },
           "Iterator": {
               "Type": "Task",
               "Resource": "arn:aws:lambda:us-east-1:123456789012:function:Iterator",
               "ResultPath": "$.iterator",
               "Next": "IsCountReached"
           },
           "IsCountReached": {
               "Type": "Choice",
               "Choices": [
                   {
                       "Variable": "$.iterator.continue",
                       "BooleanEquals": true,
                       "Next": "ExampleWork"
                   }
               ],
               "Default": "ShouldRestart"
           },
           "ExampleWork": {
               "Comment": "Your application logic, to run a specific number of times",
               "Type": "Pass",
               "Result": {
                 "success": true
               },
               "ResultPath": "$.result",
               "Next": "Iterator"
           },
           "ShouldRestart": {
             "Type": "Choice",
             "Choices": [
               {
                 "Variable": "$.restart.executionCount",
                 "NumericGreaterThan": 0,
                 "Next": "Restart"
               }
             ],
             "Default": "Done"
           },
           "Restart": {
             "Type": "Task",
             "Resource": "arn:aws:lambda:us-east-1:123456789012:function:Restart",
             "Next": "Done"
           },
           "Done": {
               "Type": "Pass",
               "End": true 
           }
       }
   }

6. 為您的狀態機器指定名稱。若要這麼做，請選擇 的預設狀態機器名稱旁的編輯圖示MyStateMachine。然後，在狀態機器組態 中，在狀態機器名稱方塊中指定名稱。

   針對本教學課程，輸入名稱 ContinueAsNew。

7. （選用） 在 狀態機器組態 中，指定其他工作流程設定，例如 狀態機器類型及其執行角色。

   在此教學課程中，請保留 狀態機器設定 中的所有預設選擇。

   如果您先前已為狀態機器建立具有正確許可IAM的角色，並想要使用它，請在許可 中，選取選擇現有角色 ，然後從清單中選擇角色。或選取輸入角色ARN，然後ARN為該IAM角色提供 。

8. 在確認角色建立對話方塊中，選擇確認以繼續。

   您也可以選擇檢視角色設定，以返回狀態機器組態 。

   注意

   如果您刪除 Step Functions 建立的角色，Step Functions 稍後無法重新建立該IAM角色。同樣地，如果您修改角色 （例如，從IAM政策的主體中移除 Step Functions），Step Functions 稍後無法還原其原始設定。

9. 將此狀態機器的 Amazon Resource Name （ARN） 儲存在文字檔案中。您需要在提供 Lambda 函數的許可ARN時提供 ，才能啟動新的 Step Functions 執行。

1. 在頁面上ContinueAsNew，選擇開始執行 。

   隨即顯示開始執行對話方塊。

2. 在啟動執行對話方塊中，執行下列動作：

   1. （選用） 輸入自訂執行名稱以覆寫產生的預設值。

      非ASCII名稱和記錄

      Step Functions 接受包含非ASCII 字元的狀態機器、執行、活動和標籤的名稱。由於此類字元不適用於 Amazon CloudWatch，因此我們建議您僅使用 ASCII 個字元，以便在 中追蹤指標 CloudWatch。

   2. 在輸入方塊中，輸入下列JSON輸入以執行工作流程。

      {
        "restart": {
          "StateMachineArn": "arn:aws:states:us-east-1:123456789012:stateMachine:ContinueAsNew",
          "executionCount": 4
        }
      }
              

   3. 使用 ContinueAsNew 狀態機器ARN的 更新 StateMachineArn 欄位。

   4. 選擇 Start execution (開始執行)。

   5. Step Functions 主控台會引導您前往標題為執行 ID 的頁面。此頁面稱為執行詳細資訊頁面。在此頁面上，您可以在執行進行時或完成後檢閱執行結果。

      若要檢閱執行結果，請在圖形檢視 上選擇個別狀態，然後選擇步驟詳情窗格上的個別索引標籤，分別檢視每個狀態的詳細資訊，包括輸入、輸出和定義。如需您可以在執行詳細資訊頁面上檢視之執行資訊的詳細資訊，請參閱 執行細節概述。

      圖形檢視會顯示四個執行中的第一個。在執行完成之前，它將通過 Restart 狀態並啟動新的執行。

      

      當此執行完成時，您可以查看正在執行的下一個執行。選取頂端ContinueAsNew的連結以查看執行清單。您應該會同時看到最近關閉的執行，以及 Restart Lambda 函數啟動的持續執行。

      所有執行完成後，您應該會在清單中看到四個成功的執行。第一個開始執行會顯示您選擇的名稱，後續的執行具有產生的名稱。