A function to consume messages for AWS SQS

consumeSqs.js

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

const sqsConfig = {
  apiVersion: "2012-11-05",
  accessKeyId: "<sqs-user's ACCESS_KEY_ID here>",
  secretAccessKey: "<sqs-user's SECRET_ACCESS_KEY here>",
  region: "AWS REGION HERE" // you can see your AWS region in your queue ARN, like:
  // arn:aws:sqs:<AWS REGION>:user-id:queue-name   
}

AWS.config.update(sqsConfig)

const createConsumer = function (queueUrl, batchSize, handler) {
  return Consumer.create({
    queueUrl: queueUrl,
    batchSize: batchSize,
    handleMessageBatch: handler,
    sqs: new AWS.SQS({
      httpOptions: {
        agent: new https.Agent({
          keepAlive: true
        })
      }
    })
  })
}

const doThisWithMessages(messages){
    // process messages in this function
    console.log(messages);
};

const sampleConsumer = createConsumer(
    "https://<QUEUE_URL_HERE -- copy from SQS console>", // URL of the queue to consume
    10, // batch size -- number of messages to consume at once, <=10
    doThisWithMessages // handler for messages
);

sampleConsumer.start()