fix(event_source): kinesis subsequenceNumber str type to int (#3275)

Co-authored-by: Leandro Damascena <[email protected]>

Author: roger-zhangg

aws_lambda_powertools/utilities/data_classes/kinesis_firehose_event.py

@@ -201,7 +201,7 @@ def sequence_number(self) -> str:
         return self._metadata["sequenceNumber"]
 
     @property
-    def subsequence_number(self) -> str:
+    def subsequence_number(self) -> int:
         """Kinesis stream sub-sequence number; present only when Kinesis Stream is source
 
         Note: this will only be present for Kinesis streams using record aggregation

aws_lambda_powertools/utilities/parser/models/kinesis_firehose.py

@@ -10,7 +10,7 @@ class KinesisFirehoseRecordMetadata(BaseModel):
     partitionKey: str
     approximateArrivalTimestamp: PositiveInt
     sequenceNumber: str
-    subsequenceNumber: str
+    subsequenceNumber: int
 
 
 class KinesisFirehoseRecord(BaseModel):

tests/events/kinesisFirehoseKinesisEvent.json

@@ -13,7 +13,7 @@
                 "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c317a",
                 "approximateArrivalTimestamp": 1664028820148,
                 "sequenceNumber": "49546986683135544286507457936321625675700192471156785154",
-                "subsequenceNumber": ""
+                "subsequenceNumber": 0
             }
         },
         {
@@ -25,7 +25,7 @@
                 "partitionKey": "4d1ad2b9-24f8-4b9d-a088-76e9947c318a",
                 "approximateArrivalTimestamp": 1664028793294,
                 "sequenceNumber": "49546986683135544286507457936321625675700192471156785155",
-                "subsequenceNumber": ""
+                "subsequenceNumber": 0
             }
         }
     ]

tests/unit/parser/test_kinesis_firehose.py

@@ -62,7 +62,7 @@ def test_firehose_trigger_event_kinesis_no_envelope():
 
     metadata_01: KinesisFirehoseRecordMetadata = record_01.kinesisRecordMetadata
     assert metadata_01.partitionKey == "4d1ad2b9-24f8-4b9d-a088-76e9947c317a"
-    assert metadata_01.subsequenceNumber == ""
+    assert metadata_01.subsequenceNumber == 0
     assert metadata_01.shardId == "shardId-000000000000"
     assert metadata_01.approximateArrivalTimestamp == 1664028820148
     assert metadata_01.sequenceNumber == "49546986683135544286507457936321625675700192471156785154"
@@ -74,7 +74,7 @@ def test_firehose_trigger_event_kinesis_no_envelope():
 
     metadata_02: KinesisFirehoseRecordMetadata = record_02.kinesisRecordMetadata
     assert metadata_02.partitionKey == "4d1ad2b9-24f8-4b9d-a088-76e9947c318a"
-    assert metadata_02.subsequenceNumber == ""
+    assert metadata_02.subsequenceNumber == 0
     assert metadata_02.shardId == "shardId-000000000001"
     assert metadata_02.approximateArrivalTimestamp == 1664028793294
     assert metadata_02.sequenceNumber == "49546986683135544286507457936321625675700192471156785155"