AWS Lambda CloudWatch Stream processor

lambda.js

var Buffer = require('buffer').Buffer;
var zlib = require("zlib");

exports.handler = (event, context, callback) => {
	var rawGzEnc = event.awslogs.data;
	var rawGz = Buffer.from(rawGzEnc, 'base64');
	var raw = zlib.gunzipSync(rawGz).toString();
	var data = JSON.parse(raw);

	console.log(data);
	// TODO process data
};

{ messageType: 'DATA_MESSAGE',
  owner: '123456789123',
  logGroup: 'testLogGroup',
  logStream: 'testLogStream',
  subscriptionFilters: [ 'testFilter' ],
  logEvents: [ { id: 'eventId1',
       timestamp: 1440442987000,
       message: '[ERROR] First test message' },
     { id: 'eventId2',
       timestamp: 1440442987001,
       message: '[ERROR] Second test message' } ] }