A node.js example using the aws-sdk to consumer data

SQS - consumer node.js

const AWS = require('aws-sdk');

AWS.config.update({
  region: 'us-east-1'
});

const SQS = new AWS.SQS();

const { 
  Consumer 
} = require('sqs-consumer'); 

const URL = 'https://sqs.us-east-1.amazonaws.com/ssssssssssss/kyc-event-sqs';

const deleteMessage = (url, receiptHandle)=>{

  const deleteParams = {
    QueueUrl: url,
    ReceiptHandle: receiptHandle
  };

  return SQS.deleteMessage(deleteParams).promise();

}

const onMessage = async (msg)=>{

  const {
    MessageId,
    ReceiptHandle,
    Body
  } = msg;

  console.log('Received:',Body,ReceiptHandle,MessageId);

  await deleteMessage(URL,ReceiptHandle);

};

const onError = (error)=>{
  console.error('error:',error);
};

const app = Consumer.create({
  queueUrl: URL,
  handleMessage: onMessage,
  batchSize:1,
  attributeNames:['All'],
  messageAttributeNames:['All'],
  sqs: new AWS.SQS()
});

app.on('error', onError);
app.on('processing_error', onError);
app.on('empty', ()=>console.log('empty'));

app.start();

console.log('Waiting messages from queue...');