1.0.0 • Published 10 years ago
kinesis-writable v1.0.0
Kinesis Writable
npm install kinesis-writable
Stream data to an AWS Kinesis stream as fast as possible — but no faster.
Newline are treated as delimiters.
Example
// stdin.js
var kpw = require('kinesis-writable')
var stream = kpw.create('your-stream-name', {region: 'us-west-2'}, function (data) {
return doSomethingWithDataToDecidePartitionKey(data)
})
process.stdin.pipe(stream)
echo -n "hello\nworld" | node stdin.js
# Writes "hello" and "world" as individual records to Kinesis
1.0.0
10 years ago