chore: explicit DynamoDB Stream schema naming

Author: heitorlessa

aws_lambda_powertools/utilities/parser/envelopes/dynamodb.py

@@ -4,7 +4,7 @@
 from pydantic import BaseModel
 from typing_extensions import Literal
 
-from ..schemas import DynamoDBSchema
+from ..schemas import DynamoDBStreamSchema
 from .base import BaseEnvelope
 
 logger = logging.getLogger(__name__)
@@ -32,7 +32,7 @@ def parse(self, data: Dict[str, Any], schema: BaseModel) -> List[Dict[Literal["N
         List
             List of records parsed with schema provided
         """
-        parsed_envelope = DynamoDBSchema(**data)
+        parsed_envelope = DynamoDBStreamSchema(**data)
         output = []
         for record in parsed_envelope.Records:
             output.append(

aws_lambda_powertools/utilities/parser/schemas/__init__.py

@@ -1,12 +1,12 @@
-from .dynamodb import DynamoDBSchema, DynamoRecordSchema, DynamoScheme
+from .dynamodb import DynamoDBStreamChangedRecordSchema, DynamoDBStreamRecordSchema, DynamoDBStreamSchema
 from .event_bridge import EventBridgeSchema
 from .sqs import SqsRecordSchema, SqsSchema
 
 __all__ = [
-    "DynamoDBSchema",
+    "DynamoDBStreamSchema",
     "EventBridgeSchema",
-    "DynamoScheme",
-    "DynamoRecordSchema",
+    "DynamoDBStreamChangedRecordSchema",
+    "DynamoDBStreamRecordSchema",
     "SqsSchema",
     "SqsRecordSchema",
 ]

aws_lambda_powertools/utilities/parser/schemas/dynamodb.py

@@ -5,7 +5,7 @@
 from typing_extensions import Literal
 
 
-class DynamoScheme(BaseModel):
+class DynamoDBStreamChangedRecordSchema(BaseModel):
     ApproximateCreationDateTime: Optional[date]
     Keys: Dict[str, Dict[str, Any]]
     NewImage: Optional[Dict[str, Any]]
@@ -31,16 +31,16 @@ class UserIdentity(BaseModel):
     principalId: Literal["dynamodb.amazonaws.com"]
 
 
-class DynamoRecordSchema(BaseModel):
+class DynamoDBStreamRecordSchema(BaseModel):
     eventID: str
     eventName: Literal["INSERT", "MODIFY", "REMOVE"]
     eventVersion: float
     eventSource: Literal["aws:dynamodb"]
     awsRegion: str
     eventSourceARN: str
-    dynamodb: DynamoScheme
+    dynamodb: DynamoDBStreamChangedRecordSchema
     userIdentity: Optional[UserIdentity]
 
 
-class DynamoDBSchema(BaseModel):
-    Records: List[DynamoRecordSchema]
+class DynamoDBStreamSchema(BaseModel):
+    Records: List[DynamoDBStreamRecordSchema]

tests/functional/parser/schemas.py

@@ -4,9 +4,9 @@
 from typing_extensions import Literal
 
 from aws_lambda_powertools.utilities.parser.schemas import (
-    DynamoDBSchema,
-    DynamoRecordSchema,
-    DynamoScheme,
+    DynamoDBStreamChangedRecordSchema,
+    DynamoDBStreamRecordSchema,
+    DynamoDBStreamSchema,
     EventBridgeSchema,
     SqsRecordSchema,
     SqsSchema,
@@ -18,17 +18,17 @@ class MyDynamoBusiness(BaseModel):
     Id: Dict[Literal["N"], int]
 
 
-class MyDynamoScheme(DynamoScheme):
+class MyDynamoScheme(DynamoDBStreamChangedRecordSchema):
     NewImage: Optional[MyDynamoBusiness]
     OldImage: Optional[MyDynamoBusiness]
 
 
-class MyDynamoRecordSchema(DynamoRecordSchema):
+class MyDynamoDBStreamRecordSchema(DynamoDBStreamRecordSchema):
     dynamodb: MyDynamoScheme
 
 
-class MyAdvancedDynamoBusiness(DynamoDBSchema):
-    Records: List[MyDynamoRecordSchema]
+class MyAdvancedDynamoBusiness(DynamoDBStreamSchema):
+    Records: List[MyDynamoDBStreamRecordSchema]
 
 
 class MyEventbridgeBusiness(BaseModel):