Merging from develop

Author: leandrodamascena

.github/workflows/secure_workflows.yml

@@ -32,7 +32,7 @@ jobs:
       - name: Checkout code
         uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8  # v6.0.1
       - name: Ensure 3rd party workflows have SHA pinned
-        uses: zgosalvez/github-actions-ensure-sha-pinned-actions@9e9574ef04ea69da568d6249bd69539ccc704e74 # v4.0.0
+        uses: zgosalvez/github-actions-ensure-sha-pinned-actions@6124774845927d14c601359ab8138699fa5b70c3 # v4.0.1
         with:
           allowlist: |
             slsa-framework/slsa-github-generator

CHANGELOG.md

@@ -6,6 +6,7 @@
 
 ## Bug Fixes
 
+* **batch_processor:** fix batch processor ([#7798](https://github.com/aws-powertools/powertools-lambda-python/issues/7798))
 * **ci:** add missing dollar signs in SSM parameter path variables ([#7695](https://github.com/aws-powertools/powertools-lambda-python/issues/7695))
 * **data-classes:** ensure lazy initialization for Cognito token generation response properties ([#7653](https://github.com/aws-powertools/powertools-lambda-python/issues/7653))
 
@@ -15,52 +16,62 @@
 
 ## Documentation
 
+* add EF Education First as customer reference ([#7809](https://github.com/aws-powertools/powertools-lambda-python/issues/7809))
 * clarify BedrockResponse.is_json() always returns True ([#7748](https://github.com/aws-powertools/powertools-lambda-python/issues/7748))
+* **event-handler:** add docstring for serializer in `BedrockAgentFunctionResolver` ([#7808](https://github.com/aws-powertools/powertools-lambda-python/issues/7808))
 
 ## Maintenance
 
-* **ci:** new pre-release 3.23.1a7 ([#7740](https://github.com/aws-powertools/powertools-lambda-python/issues/7740))
-* **ci:** new pre-release 3.23.1a5 ([#7725](https://github.com/aws-powertools/powertools-lambda-python/issues/7725))
 * **ci:** new pre-release 3.23.1a0 ([#7685](https://github.com/aws-powertools/powertools-lambda-python/issues/7685))
-* **ci:** new pre-release 3.23.1a6 ([#7733](https://github.com/aws-powertools/powertools-lambda-python/issues/7733))
-* **ci:** new pre-release 3.23.1a3 ([#7710](https://github.com/aws-powertools/powertools-lambda-python/issues/7710))
+* **ci:** new pre-release 3.23.1a4 ([#7715](https://github.com/aws-powertools/powertools-lambda-python/issues/7715))
+* **ci:** new pre-release 3.23.1a7 ([#7740](https://github.com/aws-powertools/powertools-lambda-python/issues/7740))
 * **ci:** new pre-release 3.23.1a1 ([#7697](https://github.com/aws-powertools/powertools-lambda-python/issues/7697))
-* **ci:** new pre-release 3.23.1a2 ([#7706](https://github.com/aws-powertools/powertools-lambda-python/issues/7706))
 * **ci:** new pre-release 3.23.1a8 ([#7753](https://github.com/aws-powertools/powertools-lambda-python/issues/7753))
-* **ci:** new pre-release 3.23.1a4 ([#7715](https://github.com/aws-powertools/powertools-lambda-python/issues/7715))
-* **deps:** bump redis from 6.4.0 to 7.0.1 ([#7687](https://github.com/aws-powertools/powertools-lambda-python/issues/7687))
+* **ci:** new pre-release 3.23.1a2 ([#7706](https://github.com/aws-powertools/powertools-lambda-python/issues/7706))
+* **ci:** new pre-release 3.23.1a3 ([#7710](https://github.com/aws-powertools/powertools-lambda-python/issues/7710))
+* **ci:** new pre-release 3.23.1a5 ([#7725](https://github.com/aws-powertools/powertools-lambda-python/issues/7725))
+* **ci:** new pre-release 3.23.1a6 ([#7733](https://github.com/aws-powertools/powertools-lambda-python/issues/7733))
+* **deps:** bump codecov/codecov-action from 5.5.1 to 5.5.2 ([#7788](https://github.com/aws-powertools/powertools-lambda-python/issues/7788))
 * **deps:** bump actions/checkout from 6.0.0 to 6.0.1 ([#7766](https://github.com/aws-powertools/powertools-lambda-python/issues/7766))
+* **deps:** bump datadog-lambda from 8.116.0 to 8.118.0 ([#7785](https://github.com/aws-powertools/powertools-lambda-python/issues/7785))
+* **deps:** bump urllib3 from 2.5.0 to 2.6.0 in /docs ([#7778](https://github.com/aws-powertools/powertools-lambda-python/issues/7778))
+* **deps:** bump protobuf from 6.33.1 to 6.33.2 ([#7786](https://github.com/aws-powertools/powertools-lambda-python/issues/7786))
+* **deps:** bump valkey-glide from 2.2.1 to 2.2.2 ([#7802](https://github.com/aws-powertools/powertools-lambda-python/issues/7802))
+* **deps:** bump actions/setup-node from 6.0.0 to 6.1.0 ([#7773](https://github.com/aws-powertools/powertools-lambda-python/issues/7773))
+* **deps:** bump actions/upload-artifact from 5.0.0 to 6.0.0 ([#7800](https://github.com/aws-powertools/powertools-lambda-python/issues/7800))
+* **deps:** bump actions/download-artifact from 6.0.0 to 7.0.0 ([#7801](https://github.com/aws-powertools/powertools-lambda-python/issues/7801))
 * **deps:** bump mkdocs-llmstxt from 0.4.0 to 0.5.0 in /docs ([#7720](https://github.com/aws-powertools/powertools-lambda-python/issues/7720))
+* **deps:** bump actions/setup-go from 6.0.0 to 6.1.0 ([#7718](https://github.com/aws-powertools/powertools-lambda-python/issues/7718))
 * **deps:** bump actions/checkout from 5.0.1 to 6.0.0 ([#7719](https://github.com/aws-powertools/powertools-lambda-python/issues/7719))
-* **deps:** bump actions/setup-node from 6.0.0 to 6.1.0 ([#7773](https://github.com/aws-powertools/powertools-lambda-python/issues/7773))
+* **deps:** bump protobuf from 6.33.0 to 6.33.1 ([#7681](https://github.com/aws-powertools/powertools-lambda-python/issues/7681))
 * **deps:** bump actions/checkout from 5.0.0 to 5.0.1 ([#7701](https://github.com/aws-powertools/powertools-lambda-python/issues/7701))
 * **deps:** bump valkey-glide from 2.1.1 to 2.2.1 ([#7783](https://github.com/aws-powertools/powertools-lambda-python/issues/7783))
-* **deps:** bump actions/setup-go from 6.0.0 to 6.1.0 ([#7718](https://github.com/aws-powertools/powertools-lambda-python/issues/7718))
-* **deps:** bump datadog-lambda from 8.116.0 to 8.118.0 ([#7785](https://github.com/aws-powertools/powertools-lambda-python/issues/7785))
-* **deps:** bump protobuf from 6.33.1 to 6.33.2 ([#7786](https://github.com/aws-powertools/powertools-lambda-python/issues/7786))
-* **deps:** bump protobuf from 6.33.0 to 6.33.1 ([#7681](https://github.com/aws-powertools/powertools-lambda-python/issues/7681))
-* **deps:** bump urllib3 from 2.5.0 to 2.6.0 in /docs ([#7778](https://github.com/aws-powertools/powertools-lambda-python/issues/7778))
-* **deps:** bump valkey-glide from 2.2.1 to 2.2.2 ([#7802](https://github.com/aws-powertools/powertools-lambda-python/issues/7802))
+* **deps:** bump redis from 6.4.0 to 7.0.1 ([#7687](https://github.com/aws-powertools/powertools-lambda-python/issues/7687))
+* **deps-dev:** bump boto3-stubs from 1.41.2 to 1.41.5 ([#7768](https://github.com/aws-powertools/powertools-lambda-python/issues/7768))
+* **deps-dev:** bump aws-cdk from 2.1032.0 to 2.1033.0 ([#7713](https://github.com/aws-powertools/powertools-lambda-python/issues/7713))
 * **deps-dev:** bump boto3-stubs from 1.40.75 to 1.40.76 ([#7714](https://github.com/aws-powertools/powertools-lambda-python/issues/7714))
+* **deps-dev:** bump boto3-stubs from 1.40.76 to 1.41.1 ([#7727](https://github.com/aws-powertools/powertools-lambda-python/issues/7727))
+* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.225.0a0 to 2.227.0a0 ([#7730](https://github.com/aws-powertools/powertools-lambda-python/issues/7730))
+* **deps-dev:** bump aws-cdk-lib from 2.227.0 to 2.231.0 ([#7771](https://github.com/aws-powertools/powertools-lambda-python/issues/7771))
 * **deps-dev:** bump cfn-lint from 1.40.4 to 1.41.0 ([#7709](https://github.com/aws-powertools/powertools-lambda-python/issues/7709))
 * **deps-dev:** bump sentry-sdk from 2.44.0 to 2.45.0 ([#7708](https://github.com/aws-powertools/powertools-lambda-python/issues/7708))
-* **deps-dev:** bump aws-cdk from 2.1032.0 to 2.1033.0 ([#7713](https://github.com/aws-powertools/powertools-lambda-python/issues/7713))
-* **deps-dev:** bump ruff from 0.14.5 to 0.14.6 ([#7728](https://github.com/aws-powertools/powertools-lambda-python/issues/7728))
+* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.227.0a0 to 2.231.0a0 ([#7767](https://github.com/aws-powertools/powertools-lambda-python/issues/7767))
+* **deps-dev:** bump ruff from 0.14.6 to 0.14.7 ([#7770](https://github.com/aws-powertools/powertools-lambda-python/issues/7770))
 * **deps-dev:** bump boto3-stubs from 1.40.73 to 1.40.74 ([#7703](https://github.com/aws-powertools/powertools-lambda-python/issues/7703))
 * **deps-dev:** bump types-python-dateutil from 2.9.0.20251108 to 2.9.0.20251115 ([#7702](https://github.com/aws-powertools/powertools-lambda-python/issues/7702))
-* **deps-dev:** bump boto3-stubs from 1.40.76 to 1.41.1 ([#7727](https://github.com/aws-powertools/powertools-lambda-python/issues/7727))
+* **deps-dev:** bump ruff from 0.14.5 to 0.14.6 ([#7728](https://github.com/aws-powertools/powertools-lambda-python/issues/7728))
 * **deps-dev:** bump aws-cdk from 2.1031.2 to 2.1032.0 ([#7700](https://github.com/aws-powertools/powertools-lambda-python/issues/7700))
-* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.225.0a0 to 2.227.0a0 ([#7730](https://github.com/aws-powertools/powertools-lambda-python/issues/7730))
+* **deps-dev:** bump aws-cdk-lib from 2.232.1 to 2.232.2 ([#7816](https://github.com/aws-powertools/powertools-lambda-python/issues/7816))
 * **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.224.0a0 to 2.225.0a0 ([#7704](https://github.com/aws-powertools/powertools-lambda-python/issues/7704))
 * **deps-dev:** bump boto3-stubs from 1.40.72 to 1.40.73 ([#7688](https://github.com/aws-powertools/powertools-lambda-python/issues/7688))
-* **deps-dev:** bump boto3-stubs from 1.41.2 to 1.41.5 ([#7768](https://github.com/aws-powertools/powertools-lambda-python/issues/7768))
-* **deps-dev:** bump aws-cdk-lib from 2.227.0 to 2.231.0 ([#7771](https://github.com/aws-powertools/powertools-lambda-python/issues/7771))
-* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.227.0a0 to 2.231.0a0 ([#7767](https://github.com/aws-powertools/powertools-lambda-python/issues/7767))
-* **deps-dev:** bump ruff from 0.14.6 to 0.14.7 ([#7770](https://github.com/aws-powertools/powertools-lambda-python/issues/7770))
-* **deps-dev:** bump ruff from 0.14.4 to 0.14.5 ([#7682](https://github.com/aws-powertools/powertools-lambda-python/issues/7682))
 * **deps-dev:** bump boto3-stubs from 1.42.4 to 1.42.6 ([#7791](https://github.com/aws-powertools/powertools-lambda-python/issues/7791))
-* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.223.0a0 to 2.224.0a0 ([#7680](https://github.com/aws-powertools/powertools-lambda-python/issues/7680))
 * **deps-dev:** bump boto3-stubs from 1.42.6 to 1.42.7 ([#7796](https://github.com/aws-powertools/powertools-lambda-python/issues/7796))
+* **deps-dev:** bump types-protobuf from 6.32.1.20251105 to 6.32.1.20251210 ([#7793](https://github.com/aws-powertools/powertools-lambda-python/issues/7793))
+* **deps-dev:** bump aws-cdk from 2.1033.0 to 2.1034.0 ([#7795](https://github.com/aws-powertools/powertools-lambda-python/issues/7795))
+* **deps-dev:** bump ruff from 0.14.4 to 0.14.5 ([#7682](https://github.com/aws-powertools/powertools-lambda-python/issues/7682))
+* **deps-dev:** bump sentry-sdk from 2.45.0 to 2.47.0 ([#7790](https://github.com/aws-powertools/powertools-lambda-python/issues/7790))
+* **deps-dev:** bump aws-cdk-aws-lambda-python-alpha from 2.223.0a0 to 2.224.0a0 ([#7680](https://github.com/aws-powertools/powertools-lambda-python/issues/7680))
+* **deps-dev:** bump cfn-lint from 1.41.0 to 1.42.0 ([#7784](https://github.com/aws-powertools/powertools-lambda-python/issues/7784))
 * **deps-dev:** bump mypy-boto3-appconfigdata from 1.40.55 to 1.41.0 in the boto-typing group ([#7721](https://github.com/aws-powertools/powertools-lambda-python/issues/7721))
 
 

README.md

@@ -64,6 +64,7 @@ The following companies, among others, use Powertools:
 * [CPQi (Exadel Financial Services)](https://cpqi.com/)
 * [CloudZero](https://www.cloudzero.com/)
 * [CyberArk](https://www.cyberark.com/)
+* [EF Education First](https://www.ef.com/)
 * [Flyweight](https://flyweight.io/)
 * [globaldatanet](https://globaldatanet.com/)
 * [Guild](https://guild.com/)

aws_lambda_powertools/event_handler/bedrock_agent_function.py

@@ -133,6 +133,12 @@ def lambda_handler(event, context):
     context: dict
 
     def __init__(self, serializer: Callable | None = None) -> None:
+        """
+        Parameters
+        ----------
+        serializer: Callable, optional
+            function to serialize `obj` to a JSON formatted `str`, by default json.dumps
+        """
         self._tools: dict[str, dict[str, Any]] = {}
         self.current_event: BedrockAgentFunctionEvent | None = None
         self.context = {}

aws_lambda_powertools/utilities/parser/models/__init__.py

@@ -66,6 +66,7 @@
 )
 from .dynamodb import (
     DynamoDBStreamChangedRecordModel,
+    DynamoDBStreamLambdaOnFailureDestinationModel,
     DynamoDBStreamModel,
     DynamoDBStreamRecordModel,
 )
@@ -173,6 +174,7 @@
     "DynamoDBStreamModel",
     "EventBridgeModel",
     "DynamoDBStreamChangedRecordModel",
+    "DynamoDBStreamLambdaOnFailureDestinationModel",
     "DynamoDBStreamRecordModel",
     "DynamoDBStreamChangedRecordModel",
     "KinesisDataStreamModel",

aws_lambda_powertools/utilities/parser/models/dynamodb.py

@@ -2,7 +2,8 @@
 from datetime import datetime
 from typing import Any, Dict, List, Literal, Optional, Type, Union
 
-from pydantic import BaseModel, Field, field_validator
+from pydantic import BaseModel, ConfigDict, Field, field_validator
+from pydantic.alias_generators import to_camel
 
 from aws_lambda_powertools.shared.dynamodb_deserializer import TypeDeserializer
 
@@ -110,3 +111,91 @@ class DynamoDBStreamModel(BaseModel):
             },
         ],
     )
+
+
+class DDBStreamBatchInfo(BaseModel):
+    model_config = ConfigDict(alias_generator=to_camel)
+
+    approximate_arrival_of_first_record: datetime = Field(
+        description="The approximate date and time when the first stream record from the batch was created"
+        ", in ISO-8601 format.",
+        examples=["1970-01-01T00:00:00.000Z"],
+    )
+    approximate_arrival_of_last_record: datetime = Field(
+        description="The approximate date and time when the last stream record from the batch was created"
+        ", in ISO-8601 format.",
+        examples=["1970-01-01T00:00:00.000Z"],
+    )
+    batch_size: int = Field(
+        description="The size of the batch.",
+        examples=[1],
+    )
+    end_sequence_number: str = Field(
+        description="The unique identifier of the last stream record from the batch.",
+        examples=["222"],
+    )
+    shard_id: str = Field(
+        description="The unique identifier of the DynamoDB Stream shard that contains the records from the batch.",
+        examples=["shardId-00000000000000000000-00000000"],
+    )
+    start_sequence_number: str = Field(
+        description="The unique identifier of the first stream record from the batch.",
+        examples=["222"],
+    )
+    stream_arn: str = Field(
+        description="The Amazon Resource Name (ARN) of the DynamoDB stream.",
+        examples=["arn:aws:dynamodb:us-west-2:123456789012:table/ExampleTable/stream/2021-01-01T00:00:00.000"],
+    )
+
+
+class RequestContext(BaseModel):
+    model_config = ConfigDict(alias_generator=to_camel)
+
+    approximate_invoke_count: int = Field(
+        description="The number of Lambda invocations for the record.",
+        examples=[1],
+    )
+    condition: str = Field(
+        description="The condition that caused the record to be discarded.",
+        examples=["RetryAttemptsExhausted"],
+    )
+    function_arn: str = Field(
+        description="The Amazon Resource Name (ARN) of the Lambda.",
+        examples=["arn:aws:lambda:eu-west-1:809313241:function:test"],
+    )
+    request_id: str = Field(
+        description="The unique identifier of the request.",
+    )
+
+
+class ResponseContext(BaseModel):
+    model_config = ConfigDict(alias_generator=to_camel)
+
+    executed_version: str = Field(
+        description="The version of the Lambda executed",
+        examples=["$LATEST"],
+    )
+    function_error: str = Field(
+        description="",
+        examples=["Unhandled"],
+    )
+    status_code: int = Field(
+        description="The status code returned by the Lambda",
+    )
+
+
+# https://docs.aws.amazon.com/lambda/latest/dg/services-dynamodb-errors.html
+class DynamoDBStreamLambdaOnFailureDestinationModel(BaseModel):
+    model_config = ConfigDict(alias_generator=to_camel)
+
+    ddb_stream_batch_info: DDBStreamBatchInfo = Field(alias="DDBStreamBatchInfo")
+    request_context: RequestContext
+    response_context: ResponseContext
+    timestamp: datetime = Field(
+        description="The record time, in ISO-8601 format.",
+        examples=["1970-01-01T00:00:00.000Z"],
+    )
+    version: str = Field(
+        description="The version of the record format.",
+        examples=["1.0"],
+    )