added check for ignoring null messages

Author: himanshu219

cloudwatchlogs-with-dlq/cloudwatchlogs_lambda.js

@@ -83,7 +83,10 @@ function createRecords(config, events, awslogsData) {
             log.logStream = awslogsData.logStream;
             log.logGroup = awslogsData.logGroup;
         }
-        records.push(log);
+        if (log.message) {
+            // ignoring null & undefined messages
+            records.push(log);
+        }
     });
     return records;
 }

cloudwatchlogs/cloudwatchlogs_lambda.js

@@ -216,11 +216,15 @@ exports.handler = function (event, context, callback) {
 
             var metadataKey = sumoMetaKey(awslogsData, log.message);
 
-            if (metadataKey in messageList) {
-                messageList[metadataKey].push(log);
-            } else {
-                messageList[metadataKey] = [log];
+            if (log.message) {
+                // ignoring null & undefined messages
+                if (metadataKey in messageList) {
+                    messageList[metadataKey].push(log);
+                } else {
+                    messageList[metadataKey] = [log];
+                }
             }
+
         });
 
         // Push messages to Sumo