AWS Step Functions 使用案例

在此簡單的銀行系統範例中，驗證客戶名稱與地址後，會建立一個新的銀行帳號。該工作流程由兩個 Lambda 函數 CheckName 和 CheckAddress 開始，以任務狀態並行執行。一旦兩者皆已完成，該工作流程會執行 ApproveApplication Lambda 函數。您可以定義重試並掌握條款，以處理來自任務狀態的錯誤。您可以使用工作流程中由 Lambda 函數產生的預先定義的系統錯誤或處理自訂錯誤。因為您的工作流程程式碼負責處理錯誤，所以 Lambda 函數可以專注於商務邏輯並且使用較少程式碼。Express 工作流程更適合此範例，因為 Lambda 函數執行的任務加起來用時少於五分鐘，並且沒有外部相依性。 

有時您可能需要靠人工來檢視並核准或拒絕商業流程中的某個步驟，讓工作流程繼續進行到下一步。當工作流程需要等待人工，或外部系統響應時間可能超過五分鐘的流程，我們會建議您使用 Standard 工作流程。在此，我們透過中間的通知核准者步驟擴展了新的開立帳戶流程。該工作流程從並行執行的 CheckName 和 CheckAddress 任務狀態開始。下一個 ReviewRequired 狀態為一個選擇狀態，其有兩個可能的路徑 - 傳送 SNS 通知電子郵件給 NotifyApprover 任務中的核准者，或者進入 ApproveApplication 狀態。NotifyApprover 任務狀態會寄送電子郵件給核准者，並且在繼續進行到下一個選擇狀態「已核准」前，等待回應。根據核准者的決定，透過 Lambda 函數核准或拒絕帳戶申請，

在此範例中，自訂 Eventbridge 匯流排上的事件滿足一條規則，並叫用 Step Functions 工作流程當作目標。假設您有一個自訂客戶服務應用程式，該應用程式需要處理過期的客戶訂閱。EventBridge 規則會接聽訂閱過期事件，並叫用目標工作流程進行回應。訂閱過期工作流程將停用過期訂閱擁有的所有資源，而不會刪除這些資源，並透過電子郵件通知客戶訂閱過期一事。可以使用 Lambda 函數並行完成這兩個動作。在工作流程結束時，會透過 Lambda 函數傳送一個新事件到事件匯流排，指示已處理訂閱過期。在這個範例中，我們建議使用 Express 工作流程。隨著您的業務擴展，並開始將更多事件放到事件匯流排上，Express 工作流程每秒叫用 100,000 個工作流程執行的能力非常強大。請參閱此 Github 儲存庫中的實際應用範例。

您可以使用 AWS Step Functions，建立回應包含手動核准步驟的工作流程的自動化安全事件。在此範例中，建立 IAM 政策時，會觸發 Step Functions 工作流程。工作流程將政策動作與受限動作的自訂清單相比較。工作流程會暫時回復策略，接著通知管理員並等待他們核准或拒絕。您可以延伸此工作流程以自動修復，例如將備用動作或限制動作套用到特定 ARN。請在這裡參閱範例的實際應用。

透過自動化對 AWS 資源的營運事件做出回應，您可以減少維護 AWS 雲端基礎設施的營運開銷。Amazon EventBridge 提供近乎即時的系統事件串流，以描述多數 AWS 資源的變化並提供通知。從此串流中，您可以建立規則以將特定事件路由到 AWS Step Functions、AWS Lambda，以及其他 AWS 服務，以進一步處理並自動化動作。在此範例中，基於來自 AWS Health 的事件觸發了 AWS Step Functions 工作流程。AWS 會主動監控已被公開暴露的 IAM 存取金鑰的熱門程式碼儲存庫網站。假設有一個 IAM 存取金鑰在 GitHub 上曝光了。AWS Health 會在與暴露的金鑰相關的 AWS 帳戶中產生一個 AWS_RISK_CREDENTIALS_EXPOSED 事件。設定的 Amazon Eventbridge 規則偵測此事件並叫用 Step Functions 工作流程。有了 AWS Lambda 函數的協助，工作流程接著會刪除暴露的 IAM 存取金鑰，匯總暴露的金鑰最近的 API 活動，並將摘要訊息傳送到 Amazon SNS 主題以通知訂閱者，按照此順序進行。請在這裡參閱範例的實際應用。

您可以使用 Amazon S3 託管靜態網站，以及使用 Amazon CloudFront 將內容分發到全世界。身為網站擁有者，您可能會需要兩個 S3 儲存貯體來上傳網站資料：一個用於暫存和測試，另一個用於製作。您想要使用暫存儲存貯體中的所有變更，來更新製作儲存貯體，而不需在每次更新網站時，從頭開始建立新的儲存貯體。在此範例中，Step Functions 工作流程在兩個並行且獨立的循環中執行任務：一個循環將所有物件從來源儲存貯體複製到目標儲存貯體，但忽略目標儲存貯體中已存在的物件。第二個循環刪除在來源儲存貯體中找不到的目標儲存貯體中的任何物件。一組 AWS Lambda 函數執行各個步驟：驗證輸入、從來源和目標儲存貯體中取得物件列表，以及批次複製或刪除物件。在這裡參閱範例與其程式碼的詳細資訊。在這裡了解如何在您的狀態機器中建立執行的平行分支的更多資訊。

在此範例中，Freebird 建置了一個資料處理管道，即時處理來自多個來源的 Webhook 資料，並且執行修改資料的 Lambda 函數。在這個使用案例中，來自好幾個第三方應用程式的 Webhook 資料，透過 Amazon API Gateway 傳送到 Amazon Kinesis 資料串流。AWS Lambda 函數從該 Kinesis 串流中提取資料，並觸發 Express 工作流程。此工作流程透過一系列步驟來驗證、處理和標準化此資料。最後，Lambda 函數會更新 SNS 主題，該主題透過 SQS 佇列觸發訊息到下游 Lambda 函數以進行後續步驟。您每秒最多可以叫用此工作流程 100,000 次，以擴展資料處理管道。

您可以使用 Step Functions 協同運作具有不同資料來源和目標的 ETL 流程的所有步驟。 

在此範例中，每當新資料在來源 S3 儲存貯體中可用時，Step Functions ETL 工作流程就會重新整理 Amazon Redshift。Step Functions 狀態機器會初始化一個 AWS Batch 任務，並監控其完成或錯誤的狀態。AWS Batch 任務從來源 (例如：Amazon S3) 擷取 ETL 工作流程 .sql script，並透過 PL/SQL 容器重新整理目標 (例如：Amazon Redshift)。.sql 檔案包含資料轉換中的每一個步驟的 SQL 程式碼。您可以透過 EventBridge 事件或手動透過 AWS CLI 或使用 AWS SDK 甚至自定自動化指令碼，來觸發 ETL 工作流程。您可以透過觸發電子郵件的 SNS 提醒管理員，工作流程的任何步驟或工作流程結束時發生故障。該 ETL 工作流程就是您可以使用 Standard 工作流程的一個範例。請在這裡參閱此範例詳細資訊。您可以在這裡了解更多透過範例專案提交 AWS Batch 任務的相關資訊。

擷取、轉換和載入 (ETL) 操作將原始資料轉換為有用的資料集，將資料轉變為可行的見解。 

您可以使用 Step Functions 並行執行多個 ETL 任務，其中您的來源資料集可能在不同時間為可用狀態，並且每個 ETL 任務只有在其對應的資料集可用時才會觸發。這些 ETL 任務可由不同的 AWS 服務管理，例如 AWS Glue、Amazon EMR、Amazon Athena 或其他非 AWS 服務。
在此範例中，您在 AWS Glue 上執行兩個獨立的 ETL 任務，分別處理銷售資料集和行銷資料集。一旦兩個資料集都處理完之後，第三個 ETL 任務會整合之前 ETL 任務的輸出，以產生整合資料集。Step Functions 工作流程會等到資料在 S3 中可用為止。當主要工作流程按照排程啟動時，在 Amazon S3 儲存貯體上設定了一個 EventBridge 事件處理常式，以便在將銷售或行銷資料集檔案上傳到儲存貯體時，狀態機器可以觸發 ETL 任務 “ProcessSales Data” 或 “ProcessMarketingData”，觸發取決於哪一個資料集變成可用狀態。 

在這裡參閱架構細節，在您的 AWS 帳戶中設定 ETL 協同運作架構。在這裡了解如何管理來自 Step Functions 的 AWS Batch 任務。

您可以使用 Step Functions 在資料集中重複使用超過數以千萬計的項目，例如 JSON 陣列、S3 中的物件清單或 S3 儲存貯體中的 CSV 檔案。您接著可以使用高並行性並行處理資料。

在此範例中，Step Functions 工作流程使用分散式模式中的對應狀態來處理 S3 儲存貯體中的 S3 物件列表。Step Functions 重複使用物件清單，接著啟動數千個同時執行的平行工作流程來處理項目。您可以使用運算服務，例如 Lambda，協助您以任何受支援的語言撰寫程式碼。您也可以從超過 220 種專用 AWS 服務中進行選擇，以將其包含在對應狀態工作流程中。一旦子工作流程執行完畢，Step Functions 就可以將結果匯出至 S3 儲存貯體，以供審查或進一步處理。