AWS Lambda事件反序列化

Question

有没有人成功地为 S3 事件实施了基于 Java 的请求处理程序？

我的班级:

package example;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.amazonaws.services.s3.model.S3Event;

public class Hello implements RequestHandler<S3Event, String> {
    public String handleRequest(S3Event event, Context context) {
        return "Success";
    }
}

错误消息：

JSON 解析期间发生错误：java.lang.RuntimeException java.lang.RuntimeException：JSON 解析期间发生错误 由以下原因引起：java.io.UncheckedIOException： com.fasterxml.jackson.databind.JsonMappingException： 无法反序列化 com.amazonaws.services.s3.model.S3Event 的实例 从 START_OBJECT 令牌中解脱 [来源： lambdainternal.util.NativeMemoryAsInputStream@6108b2d7; 行： 1， 列： 1] 由： com.fasterxml.jackson.databind.JsonMappingException： 不能反序列化 com.amazonaws.services.s3.model.S3Event 的实例 out of START_OBJECT 令牌 at [来源： lambdainternal.util.NativeMemoryAsInputStream@6108b2d7; 行： 1， 列： 1] at com.fasterxml.jackson.databind.JsonMappingException.from（JsonMappingException.java：148） at com.fasterxml.jackson.databind.DeserializationContext.mappingException（DeserializationContext.java：835） at com.fasterxml.jackson.databind.DeserializationContext.mappingException（DeserializationContext.java：831） at com.fasterxml.jackson.databind.deser.std.EnumDeserializer._deserializeOther（EnumDeserializer.java：137） at com.fasterxml.jackson.databind.deser.std.EnumDeserializer.deserialize（EnumDeserializer.java：89） at com.fasterxml.jackson.databind.deser.std.EnumDeserializer.deserialize（EnumDeserializer.java：18） at com.fasterxml.jackson.databind.ObjectReader._bindAndClose（ObjectReader.java：1441） atcom.fasterxml.jackson.databind.ObjectReader.readValue（ObjectReader.java：1047）

Answer 1

解决方案是采取S3EventNotify。希望在AWS留档中涵盖。我喜欢Lambda的概念，但没有太多的留档或示例。

public void mergeGLAU(S3EventNotification notification, Context context) {
    try {
        for (S3EventNotificationRecord record : notification.getRecords()) {
            System.out.println(record.getEventSource());
            System.out.println(record.getEventName());
            System.out.println(record.getS3().getBucket().getName());
            System.out.println(record.getS3().getObject().getKey());
        }
    }
    catch (Exception e) {
        e.printStackTrace();
    }
}