diff --git a/aws_lambda_powertools/utilities/parser/models/kinesis.py b/aws_lambda_powertools/utilities/parser/models/kinesis.py index 3817cda0852..1c7c31c97b4 100644 --- a/aws_lambda_powertools/utilities/parser/models/kinesis.py +++ b/aws_lambda_powertools/utilities/parser/models/kinesis.py @@ -4,7 +4,6 @@ from typing import List, Union from pydantic import BaseModel, validator -from pydantic.types import PositiveInt from aws_lambda_powertools.utilities.parser.types import Literal, Model @@ -14,7 +13,7 @@ class KinesisDataStreamRecordPayload(BaseModel): kinesisSchemaVersion: str partitionKey: str - sequenceNumber: PositiveInt + sequenceNumber: str data: Union[bytes, Model] # base64 encoded str is parsed into bytes approximateArrivalTimestamp: float diff --git a/tests/functional/parser/test_kinesis.py b/tests/functional/parser/test_kinesis.py index 632a7463805..552cb6cef68 100644 --- a/tests/functional/parser/test_kinesis.py +++ b/tests/functional/parser/test_kinesis.py @@ -35,7 +35,7 @@ def handle_kinesis_no_envelope(event: KinesisDataStreamModel, _: LambdaContext): assert kinesis.approximateArrivalTimestamp == 1545084650.987 assert kinesis.kinesisSchemaVersion == "1.0" assert kinesis.partitionKey == "1" - assert kinesis.sequenceNumber == 49590338271490256608559692538361571095921575989136588898 + assert kinesis.sequenceNumber == "49590338271490256608559692538361571095921575989136588898" assert kinesis.data == b"Hello, this is a test."