Wednesday, 25 June 2025

Step function

 

🔹 Common State Types in Step Functions

State TypePurpose
TaskRun a Lambda, ECS, Glue Job, etc.
ChoiceBranch logic based on input values
WaitPause execution for a period
PassPass input to output (used for testing/transition)
FailStop execution with failure
SucceedMark workflow as complete with success
ParallelRun branches concurrently
MapRun a loop over a list (like for-each)

Step Functions Definition (Amazon States Language)

json

{ "Comment": "Athena Query Orchestration", "StartAt": "StartQueryExecution", "States": { "StartQueryExecution": { "Type": "Task", "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:StartAthenaQuery", "Next": "Wait30Seconds" }, "Wait30Seconds": { "Type": "Wait", "Seconds": 30, "Next": "CheckQueryStatus" }, "CheckQueryStatus": { "Type": "Task", "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:CheckAthenaStatus", "Next": "QueryComplete?" }, "QueryComplete?": { "Type": "Choice", "Choices": [ { "Variable": "$.status", "StringEquals": "SUCCEEDED", "Next": "ProcessResults" }, { "Variable": "$.status", "StringEquals": "FAILED", "Next": "FailState" } ], "Default": "Wait30Seconds" }, "ProcessResults": { "Type": "Pass", "Result": "Athena query succeeded.", "End": true }, "FailState": { "Type": "Fail", "Error": "AthenaQueryFailed", "Cause": "Query failed" } } }

No comments:

Post a Comment