Skip to content

coryodaniel/kinesis-parser

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Kinesis Parser

Small library for reading Kinesis event.Records in Lambda.

Installing

npm install kinesis-parser --save

Parsing plain text messages

const KinesisParser = require('kinesis-parser')

exports.handler = (event, context, callback) => {
  const messages = KinesisParser.parse(event.Records)
  // filters non-kinesis records and base64 decodes kinesis.data in one pass
  // messages => [{data": "Hello World"}]
}

Parsing JSON messages

const KinesisParser = require('kinesis-parser')

exports.handler = (event, context, callback) => {
  const messages = KinesisParser.parseJSON(event.Records)
  // filters non-kinesis records and base64 decodes kinesis.data in one pass
  // parses JSON and discards records that do not parse
  // messages => [{data": {"msg":"Hello World"}},{...},...]
}

About

Parse kinesis events

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published