refactor(trigger): Split decompress and parse

For handling CloudWatchLogsEvent log data split the Decode and
decompress from the parse as CloudWatchLogsDecodedData

Author: Michael Brewer

aws_lambda_powertools/utilities/trigger/cloud_watch_logs_event.py

@@ -83,8 +83,12 @@ def aws_logs_data(self) -> str:
         """The value of the `data` field is a Base64 encoded ZIP archive."""
         return self["awslogs"]["data"]
 
-    def decode_cloud_watch_logs_data(self) -> CloudWatchLogsDecodedData:
-        """Decode, unzip and parse json data"""
+    @property
+    def decompress_logs_data(self) -> bytes:
+        """Decode and decompress log data"""
         payload = base64.b64decode(self.aws_logs_data)
-        decoded: dict = json.loads(zlib.decompress(payload, zlib.MAX_WBITS | 32).decode("UTF-8"))
-        return CloudWatchLogsDecodedData(decoded)
+        return zlib.decompress(payload, zlib.MAX_WBITS | 32)
+
+    def parse_logs_data(self) -> CloudWatchLogsDecodedData:
+        """Decode, decompress and parse json data as CloudWatchLogsDecodedData"""
+        return CloudWatchLogsDecodedData(json.loads(self.decompress_logs_data.decode("UTF-8")))

tests/functional/test_lambda_trigger_events.py

@@ -42,7 +42,7 @@ def load_event(file_name: str) -> dict:
 def test_cloud_watch_trigger_event():
     event = CloudWatchLogsEvent(load_event("cloudWatchLogEvent.json"))
 
-    decoded_data = event.decode_cloud_watch_logs_data()
+    decoded_data = event.parse_logs_data()
     log_events = decoded_data.log_events
     log_event = log_events[0]