Added do-nothing and Json serialiser transformers.

Author: IanMeyers

dist/LambdaStreamToFirehose-1.3.5.zip

@@ -120,6 +120,18 @@ exports.addNewlineTransformer = function(data, callback) {
 	callback(null, new Buffer(data + "\n", targetEncoding));
 };
 
+/** Convert JSON data to its String representation */
+exports.jsonToStringTransformer = function(data, callback) {
+	// emitting a new buffer as text with newline
+	callback(null, new Buffer(JSON.stringify(data) + "\n", targetEncoding));
+};
+
+/** literally nothing at all transformer - just wrap the object in a buffer */
+exports.doNothingTransformer = function(data, callback) {
+	// emitting a new buffer as text with newline
+	callback(null, new Buffer(data));
+};
+
 /**
  * Example transformer that converts a regular expression to delimited text
  */
@@ -143,7 +155,7 @@ exports.regexToDelimiter = function(regex, delimiter, data, callback) {
  * create the transformer instance - change this to be regexToDelimter, or your
  * own new function
  */
-var transformer = exports.addNewlineTransformer.bind(undefined);
+var transformer = exports.jsonToStringTransformer.bind(undefined);
 
 /**
  * Convenience function which generates the batch set with low and high offsets

index.js

@@ -1,31 +1,24 @@
 {
-    "name": "lambda-stream-to-firehose",
-    "description": "An AWS Lambda function that forwards data from a Kinesis or DynamoDB Update Stream to a Kinesis Firehose Delivery Stream",
-    "version": "1.3.4",
-    "dependencies": {
-    	"async":"1.5.2",
-    	"aws-kpl-deagg":"2.1.1"
-    },
-    "keywords": [
-        "amazon",
-        "aws",
-        "kinesis",
-        "firehose",
-        "lambda"
-    ],
-    "author": {
-        "name": "Ian Meyers",
-        "email": "[email protected]"
-    },
-    "main": "index.js",
-    "license" : "Apache-2.0",
-    "files": [
-        "index.js",
-        "lambda.json",
-        "tagKinesisStream.sh",
-        "package.json",
-        "README.md",
-        "LICENSE",
-        "NOTICE.txt"
-    ]
-}
+	"name": "lambda-stream-to-firehose",
+	"description": "An AWS Lambda function that forwards data from a Kinesis or DynamoDB Update Stream to a Kinesis Firehose Delivery Stream",
+	"version": "1.3.5",
+	"dependencies": 
+	{
+		"async": "1.5.2",
+		"aws-kpl-deagg": "2.1.1"
+	},
+
+	"keywords": 
+	["amazon","aws","kinesis","firehose","lambda"],
+
+	"author": 
+	{
+		"name": "Ian Meyers",
+		"email": "[email protected]"
+	},
+
+	"main": "index.js",
+	"license": "Apache-2.0",
+	"files": 
+	["index.js","lambda.json","tagKinesisStream.sh","package.json","README.md","LICENSE","NOTICE.txt"]
+}