Add example

Author: tilfin

example/async.js

@@ -0,0 +1,28 @@
+const StreamUtils = require('@tilfin/stream-utils');
+const KSL = require('../lib');
+const PromisedLife = require('promised-lifestream');
+
+exports.handler = async function (event) {
+  console.log('event: ', JSON.stringify(event, null, 2));
+
+  const result = [];
+  
+  await PromisedLife([
+    KSL.reader(event, { isAgg: false }),
+    KSL.parseJSON({ flatArray: false }),
+    StreamUtils.map(function(data, cb) {
+      result.push(data);
+      cb(null, data)
+    })
+  ])
+
+  console.dir(result);
+}
+
+exports.handler(require('./data'))
+.then(() => {
+  console.info('<<< END >>>')
+})
+.catch(err => {
+  console.error('Failed:', err)
+})

example/data.json

@@ -0,0 +1,52 @@
+{
+    "Records": [
+        {
+            "kinesis": {
+                "kinesisSchemaVersion": "1.0",
+                "partitionKey": "485bd0f3c7f8b6ec3ddc6ada18abcf8d",
+                "sequenceNumber": "49565441425403787852263465772329791873704550161163747330",
+                "data": "W3siaWQiOjEsInZhbHVlIjoxMH0seyJpZCI6MiwidmFsdWUiOjIwfSx7ImlkIjozLCJ2YWx1ZSI6MzB9LHsiaWQiOjQsInZhbHVlIjoxNX0seyJpZCI6NSwidmFsdWUiOjI1fV0=",
+                "approximateArrivalTimestamp": 1473002069.264
+            },
+            "eventSource": "aws:kinesis",
+            "eventVersion": "1.0",
+            "eventID": "shardId-000000000000:49565441425403787852263465772329791873704550161163747330",
+            "eventName": "aws:kinesis:record",
+            "invokeIdentityArn": "arn:aws:iam::986450800000:role/lambda_basic_execution",
+            "awsRegion": "ap-northeast-1",
+            "eventSourceARN": "arn:aws:kinesis:ap-northeast-1:986450800000:stream/kpl-stream"
+        },
+        {
+            "kinesis": {
+                "kinesisSchemaVersion": "1.0",
+                "partitionKey": "485bd0f3c7f8b6ec3ddc6ada18abcf8d",
+                "sequenceNumber": "49565441425403787852263465772329791873704550161163747330",
+                "data": "W3siaWQiOjEsInZhbHVlIjoxMH0seyJpZCI6MiwidmFsdWUiOjIwfSx7ImlkIjozLCJ2YWx1ZSI6MzB9LHsiaWQiOjQsInZhbHVlIjoxNX0seyJpZCI6NSwidmFsdWUiOjI1fV0=",
+                "approximateArrivalTimestamp": 1473002069.264
+            },
+            "eventSource": "aws:kinesis",
+            "eventVersion": "1.0",
+            "eventID": "shardId-000000000000:49565441425403787852263465772329791873704550161163747330",
+            "eventName": "aws:kinesis:record",
+            "invokeIdentityArn": "arn:aws:iam::986450800000:role/lambda_basic_execution",
+            "awsRegion": "ap-northeast-1",
+            "eventSourceARN": "arn:aws:kinesis:ap-northeast-1:986450800000:stream/kpl-stream"
+        },
+        {
+            "kinesis": {
+                "kinesisSchemaVersion": "1.0",
+                "partitionKey": "485bd0f3c7f8b6ec3ddc6ada18abcf8d",
+                "sequenceNumber": "49565441425403787852263465772329791873704550161163747330",
+                "data": "W3siaWQiOjEsInZhbHVlIjoxMH0seyJpZCI6MiwidmFsdWUiOjIwfSx7ImlkIjozLCJ2YWx1ZSI6MzB9LHsiaWQiOjQsInZhbHVlIjoxNX0seyJpZCI6NSwidmFsdWUiOjI1fV0=",
+                "approximateArrivalTimestamp": 1473002069.264
+            },
+            "eventSource": "aws:kinesis",
+            "eventVersion": "1.0",
+            "eventID": "shardId-000000000000:49565441425403787852263465772329791873704550161163747330",
+            "eventName": "aws:kinesis:record",
+            "invokeIdentityArn": "arn:aws:iam::986450800000:role/lambda_basic_execution",
+            "awsRegion": "ap-northeast-1",
+            "eventSourceARN": "arn:aws:kinesis:ap-northeast-1:986450800000:stream/kpl-stream"
+        }
+    ]
+}

example/normal.js

@@ -0,0 +1,30 @@
+const StreamUtils = require('@tilfin/stream-utils');
+const KSL = require('../lib');
+
+exports.handler = function (event, context, callback) {
+  console.log('event: ', JSON.stringify(event, null, 2));
+
+  const result = [];
+  const stream = KSL.reader(event, { isAgg: false });
+
+  stream.on('end', () => {
+    console.dir(result);
+    callback();
+  });
+
+  stream.on('error', err => {
+    callback(err);
+  });
+
+  stream
+  .pipe(KSL.parseJSON({ flatArray: false }))
+  .pipe(StreamUtils.map(function(data, cb) {
+    result.push(data);
+    cb(null, data)
+  }));
+}
+
+exports.handler(require('./data'), null, function (err) {
+  if (err) console.error('Failed:', err)
+  else console.info('<<< END >>>')
+})