kinesis-client

Kinesis Client

A very minimal functional wrapper around the AWS SDK to provide a Kinesis Client. I'll extend as necessary.

The idea here is that the kinesis require functions more like a namespace containing functions than as an object.

NOT PRODUCTION READY

Usage

To use in a lambda, do something like the below:

const kinesis = require('kinesis-client');

var defaultOpts = {
  endpoint: 'localhost:4567',
  region: 'us-east-1',
  apiVersion: '2013-12-02',
  sslEnabled: false
};

module.exports.source = (event, context, callback) => {
  const kinesisClient = kinesis.createClient(defaultOpts);
  var streamName = 'events';
  var streamOpts = { ShardCount: 1, StreamName: streamName }

  kinesis.createStream(kinesisClient, streamOpts);

  console.log(event.body);

  kinesis.putRecord(kinesisClient,
                    {
                     Data: JSON.stringify(event.body),
                     PartitionKey: '0', // change this!
                     StreamName: streamName
                    });
};

TODO

Add more tests!

Licence

MIT