zlib

Author: jcardus

cloudwatch-logs.mjs

@@ -1,7 +1,7 @@
 import fs from 'fs'
 import readline from 'readline'
 import rabbit from './rabbit.js'
-import zlib from 'zlib';
+import zlib from 'zlib'
 
 let counter = 0
 const lines = []
@@ -23,8 +23,11 @@ async function processLines () {
 
 export function lambda (e) {
   const payload = Buffer.from(e.awslogs.data, 'base64')
-  const data = zlib.gunzipSync(payload).toString('utf8')
-  console.log(data)
+  const json = JSON.parse(zlib.gunzipSync(payload).toString('utf8'))
+
+  for (const logEvent of json.logEvents) {
+    console.log('Message:', logEvent.message)
+  }
   setTimeout(rabbit.close, 10000)
 }