1.0.1 • Published 4 years ago
dynamo-stream v1.0.1
dynamo-stream
Promise based DynamoDB data streamer. It uses Dynamo DB Document client scan and query methods.
Install
$ npm install dynamo-stream
Basic Usage
const AWS = require('aws-sdk')
const createStreamClient = require('dynamo-stream')
const documentClient = new AWS.DynamoDB.DocumentClient()
const streamClient = createStreamClient(documentClient)
// Note: This function can return a promise that will be resolved before the
// next item gets called
function onData(item) {
console.log('Item: ', item)
}
streamClient.scan({ TableName: 'foo-table' }, onData).then(function() {
// Note: This promise resolves when the method finishes streaming every
// item returned by the scan method.
console.log('Finished')
})
queryTable = streamClient
.query(
{
TableName: 'foo-table',
KeyConditionExpression: '#user = :user',
ExpressionAttributeValues: { ':user': 'foo-user' },
ExpressionAttributeNames: { '#user': 'user' },
},
onData,
)
.then(function() {
// Note: This promise resolves when the method finishes streaming every
// item returned by the query method.
console.log('Finished')
})
1.0.1
4 years ago