sqs-producer
Enqueues messages onto a given SQS queue
Installation
npm install sqs-producer
Usage
const { Producer } = require('sqs-producer');
import AWS from 'aws-sdk'
const producer = Producer.create({
queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
region: 'eu-west-1'
});
AWS.config.update({
accessKeyId: 'yourAccessKey',
secretAccessKey: 'yourSecret',
region: 'eu-west-1',
});
const producer = Producer.create({
queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
region: 'eu-west-1',
sqs: new AWS.SQS(),
});
await producer.send(['msg1', 'msg2']);
const size = await producer.queueSize();
console.log(`There are ${size} messages on the queue.`);
await producer.send([{
id: 'id1',
body: 'Hello world'
}]);
await producer.send([
{
id: 'id1',
body: 'Hello world with two string attributes: attr1 and attr2',
messageAttributes: {
attr1: { DataType: 'String', StringValue: 'stringValue' },
attr2: { DataType: 'Binary', BinaryValue: new Buffer('binaryValue') }
}
},
{
id: 'id2',
body: 'Hello world delayed by 5 seconds',
delaySeconds: 5
}
]);
await producer.send({
id: "testId",
body: 'Hello world from our FIFO queue!',
groupId: 'group1234',
deduplicationId: 'abcdef123456'
});
Development
Test
npm test
Coverage
For coverage report, run the command:
npm run coverage
Lint
To check for problems using ESLint
npm run lint
Contributing
See contributing guildlines