@aws-cdk/aws-sqs

Create an SQS Queue

This code sample demonstrates how to create a basic SQS queue with a visibility timeout of 300 seconds using the AWS CDK.

const cdk = require('@aws-cdk/core');
const sqs = require('@aws-cdk/aws-sqs');

class MyStack extends cdk.Stack {
  constructor(scope, id, props) {
    super(scope, id, props);

    const queue = new sqs.Queue(this, 'MyQueue', {
      visibilityTimeout: cdk.Duration.seconds(300)
    });
  }
}

const app = new cdk.App();
new MyStack(app, 'MyStack');

Configure Dead-Letter Queue

This code sample shows how to configure a dead-letter queue for an SQS queue. Messages that are not successfully processed after 5 attempts will be moved to the dead-letter queue.

const cdk = require('@aws-cdk/core');
const sqs = require('@aws-cdk/aws-sqs');

class MyStack extends cdk.Stack {
  constructor(scope, id, props) {
    super(scope, id, props);

    const deadLetterQueue = new sqs.Queue(this, 'DeadLetterQueue');

    const queue = new sqs.Queue(this, 'MyQueue', {
      deadLetterQueue: {
        queue: deadLetterQueue,
        maxReceiveCount: 5
      }
    });
  }
}

const app = new cdk.App();
new MyStack(app, 'MyStack');

Integrate SQS with Lambda

This code sample demonstrates how to integrate an SQS queue with an AWS Lambda function. The Lambda function will be triggered whenever a new message is added to the SQS queue.

const cdk = require('@aws-cdk/core');
const sqs = require('@aws-cdk/aws-sqs');
const lambda = require('@aws-cdk/aws-lambda');
const lambdaEventSources = require('@aws-cdk/aws-lambda-event-sources');

class MyStack extends cdk.Stack {
  constructor(scope, id, props) {
    super(scope, id, props);

    const queue = new sqs.Queue(this, 'MyQueue');

    const myFunction = new lambda.Function(this, 'MyFunction', {
      runtime: lambda.Runtime.NODEJS_14_X,
      handler: 'index.handler',
      code: lambda.Code.fromAsset('lambda')
    });

    myFunction.addEventSource(new lambdaEventSources.SqsEventSource(queue));
  }
}

const app = new cdk.App();
new MyStack(app, 'MyStack');