A useful and easy to use library for consuming messages from SQS is sqs-consumer
const Consumer = require('sqs-consumer'); const app = Consumer.create({ queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name', handleMessage: (message, done) => { console.log('Processing message: ', message); done(); } }); app.on('error', (err) => { console.log(err.message); }); app.start();
This is well documented if you need more information. Documents can be found at: https://github.com/bbc/sqs-consumer
source share