1.0.2 • Published 5 years ago

sqs-service v1.0.2

Weekly downloads
6
License
ISC
Repository
github
Last release
5 years ago

aws-sqs-service

AWS Simple Queue Service(SQS)

Requirement

Enviroment variables - IAM credentials

export AWS_ACCESS_KEY_ID=your-id
export AWS_SECRET_ACCESS_KEY=your-secret

Install

npm i -S sqs-service

Usage

Config

const QueueService = require('aws-sqs-service');
const sqs = new QueueService(options);

options

  • region -- required
  • batchSize -- The maximum number of messages to return. valid value 1 to 10. Default 1.
  • apiVersion

Send Message to Queue

sqs.sendMessage(url, payload)  //url -> queueUrl, payload -> JSON object

Consume from Queue

sqs.consume(url, function(data, done) => {
  //doSomethingWith(data)
  //done()
  
  //doSomethingAsyncWith(data)
  //  .then(_ => done())
})