kinesis-writable

Write newline-delimited data to Kinesis.

Usage no npm install needed!

<script type="module">
  import kinesisWritable from 'https://cdn.skypack.dev/kinesis-writable';
</script>

README

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