I am creating a step function for running an ETL job when ever files are uploaded into DB. The step function involves tasks like glue jobs, crawler runs lambdas etc. I have different clients that upload data to their respective…
I am trying to make a simple step function workflow but something really, really strange is happening. I am trying to chain a "putItem" inside a dynamoDB, with a basic lambda. I am quite literally following the documentation step by…
In AWS Step Functions I have a simple state machine with three states. StateA and StateB are inside a 'Parallel' state. StateC is after the 'Parallel' state. By default, StateC is executed when both StateA and StateB are completed. However,…
I see that when we invoke a lambda, there is an x-amzn-request-id for that execution: "resourceType": "lambda", "resource": "invoke", "output": { "ExecutedVersion": "$LATEST", "Payload": { "recordsReady": false }, "SdkHttpMetadata": { "AllHttpHeaders": { "X-Amz-Executed-Version": [ "$LATEST" ], "x-amzn-Remapped-Content-Length": [ "0" ],…
The project I'm working on requires creating an DB aurora (PostgreSQL) that will invoke my step function (After every insert to X table) and gets the result from the step function to invoke a lambda function. So the question :…
I need to write some endpoint that simulate the response of third party server to run performance test regularly. I have decided to go with API Gateway to Step Function (waits 2 seconds) to Lambda that returns response based on…
We created step function (WAIT State) to execute schedule task based up on user input time. We are calling this step up function from PHP code so it will create entry in that state machine and step function (WAIT State)…
I am looking to connect my Lambda with my Step Function, and cannot figure out why it will not startExecution. SDK Code: import AWS from "aws-sdk"; const stepfunctions = new AWS.StepFunctions({ apiVersion: "2016-11-23" }); interface Params { stateMachineArn: string; input:…
I am running a state machine running a dynamodb query (called using CallAwsService). The format returned looks like this: { Items: [ { "string" : { "B": blob, "BOOL": boolean, "BS": [ blob ], "L": [ "AttributeValue" ], "M": {…
I would like to create a dynamodb step using the resource arn:aws:states:::dynamodb:getItem where some attributes may not be available. The relevant portion of my task is as follows: "Get Config": { "Type": "Task", "Resource": "arn:aws:states:::dynamodb:getItem", "Next": "DummyPass", "Parameters": { "Key":…