consume a sqs topic in typescript

Here is an example code to consume a SQS topic in TypeScript:

First, install the AWS SDK for JavaScript:


npm install aws-sdk --save
27 chars
2 lines

Add the following import statements to your TypeScript file:


index.ts
import * as AWS from 'aws-sdk';
const sqs = new AWS.SQS({ region: 'REGION' });
79 chars
3 lines

Configure your AWS credentials:


index.ts
AWS.config.update({
   accessKeyId: 'ACCESS_KEY_ID',
   secretAccessKey: 'SECRET_ACCESS_KEY',
   region: 'REGION'
});
118 chars
6 lines

Define a callback function that will be called when a message is received:


index.ts
const messageProcessor = (message: AWS.SQS.Types.Message) => {
   console.log(`Received message: ${message.Body}`);
   // Add your message processing logic here
};
164 chars
5 lines

Define the parameters for consuming messages from the SQS queue:


index.ts
const params: AWS.SQS.Types.ReceiveMessageRequest = {
   QueueUrl: 'QUEUE_URL',
   MaxNumberOfMessages: 10,
   WaitTimeSeconds: 10
};
134 chars
6 lines

Call the sqs.receiveMessage() method with the defined queue parameters and the callback function:


index.ts
sqs.receiveMessage(params, (err: any, data: AWS.SQS.Types.ReceiveMessageResult) => {
      if (err) {
         console.error(err);
      } else if (data.Messages) {
         console.log(`Processing ${data.Messages.length} messages`);
         data.Messages.forEach(messageProcessor);
      } else {
         console.log('No messages to process');
      }
});
359 chars
11 lines

This code will continuously poll the SQS queue for messages, and when a message is received your callback function will be called to process the message. The WaitTimeSeconds parameter determines how long the SQS queue will wait before returning an empty response, allowing your code to efficiently consume messages.

similar typescript code snippets

create a generic interface in typescript

store generic into localstorage in typescript

how to define an interface in typescript

check if enum is valid in typescript

a generic function for storing cache into localstorage in typescript

create a function that calculates volume of a cube in typescript

split a provided array into chunks of a provided size in typescript

split an array of generics into chunks of size n in typescript

loop in typescript

loop through enum in typescript

related categories