Failed to deserialize DynamodbEvent.DynamodbStreamRecord#dynamodb

[mo7ty]

When deserializing a DynamodbEvent, the contained DynamodbEvent.DynamodbStreamRecord#dynamodb (type: StreamRecord) is completely loaded: keys and new and old images (when present, obviously).

But when attempted to deserialize directly a DynamodbEvent.DynamodbStreamRecord, the contained DynamodbEvent.DynamodbStreamRecord#dynamodb (type: StreamRecord) is NOT loaded correctly.

Created demonstration test available at Add test for DynamodbEvent.DynamodbStreamRecord load:

• Added EventLoaderTest#testLoadDynamodbStreamRecord() fails.

Why? What am I missing?

[mo7ty]

Answering my own question...

Why?

Because the DynamodbEvent.DynamodbStreamRecord and nested classes are not registered in LambdaEventSerializers#NESTED_CLASS_MAP.

Refer to Add support for DynamodbEvent.DynamodbStreamRecord serialization #455

[mo7ty]

After Add support for DynamodbEvent.DynamodbStreamRecord serialization #455 included in aws-lambda-java-serialization v1.1.5, although everything works locally and all added tests pass successfully, when running in AWS Lambda (runtime Java17) the DynamodbEvent.DynamodbStreamRecord#dynamodb is still not parsed correctly:

{
    "eventID": "_Event::Id_",
    "awsRegion": "eu-west-1",
    "eventSourceARN": "arn:aws:dynamodb:eu-west-1:_AWS::Account_:table/_DDB::Table_/stream/_DDB::Stream::Id_",
    "eventVersion": "1.1",
    "eventSource": "aws:dynamodb",
    "eventName": "REMOVE",
    "userIdentity": null,
    "dynamodb": {
        "streamViewType": null,
        "sequenceNumber": null,
        "approximateCreationDateTime": null,
        "newImage": null,
        "keys": null,
        "oldImage": null,
        "sizeBytes": null
    }
}

Using:

import com.amazonaws.services.lambda.runtime.events.DynamodbEvent;
LambdaEventSerializers.serializerFor(DynamodbEvent.DynamodbStreamRecord.class,
                                     Thread.currentThread().getContextClassLoader());
                                     // using ClassLoader.getSystemClassLoader() fails with:
                                     // com.amazonaws.services.lambda.runtime.serialization.util.ReflectUtil$ReflectException:
                                     //     java.lang.ClassNotFoundException: org.joda.time.DateTime

Why? What am I missing?

[smirnoal]

the new version has not been deployed with managed Lambda runtimes yet. Meantime, you can use either OCI deployment or wrapper to package 1.1.5 along with your function

[mo7ty]

the new version has not been deployed with managed Lambda runtimes yet. Meantime, you can use either OCI deployment or wrapper to package 1.1.5 along with your function

Thanks @smirnoal

[smirnoal]

just checking if it works in the managed runtime now

[mo7ty]

Hi @smirnoal!
Didn't had the chance yet to include this update in the pipeline - is planned to be included during 2024 Q2 maintenance.
From my side, consider this issue closed, as it is working locally.