Resources: SNSTopic: Type: AWS::SNS::Topic Properties: TopicName: name KmsMasterKeyId: !ImportValue kms-key-id SQSQueue: Type: AWS::SQS::Queue SNSSubscription: Type: AWS::SNS::Subscription Properties: TopicArn: !Ref SNSTopicArn
Category: AWS
Step function notes
Use step function to delay sns { “StartAt”: “Delay”, “Comment”: “Publish to SNS with delay”, “States”: { “Delay”: { “Type”:
Lambda inserting into SQS using message timer
https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#sendMessage-property const AWS = require(‘aws-sdk’); exports.handler = async (event, context) => { // Get the SQS client. const sqs =
Step function history event limitation
One approach to avoid the 25k history event limit is to add a choice state in your loop that takes
Step function wait 10 seconds after current time
{ “StartAt”: “Wait”, “States”: { “Wait”: { “Type”: “Wait”, “Seconds”: { “Value”: { “Fn::Sub”: “${current_time} + 10” } }, “Next”:
Lambda executing step function nodejs example
var aws = require(‘aws-sdk’) exports.handler = (event, context, callback) => { var params = { stateMachineArn: ‘arn:aws:states:us-east-1:1234567890:stateMachine:Helloworld’, input: JSON.stringify({}) };
Step function possible states
There are 7 possible states in a Step Function: Task: A Task state represents a single unit of work performed
Async Lambda example sending task succeeded status back to step function
const AWS = require(‘aws-sdk’); exports.handler = async (event, context) => { // Get the Step Functions client. const stepFunctions =
Lambda polling SQS nodejs example
const AWS = require(‘aws-sdk’); exports.handler = async (event, context) => { // Get the SQS client. const sqs = new
Lambda invoke step function nodejs example
const AWS = require(‘aws-sdk’); exports.handler = async (event, context) => { // Get the Step Functions client. const stepFunctions =