尝试为 DynamoDB 初始化客户端时,Amazon Lambda 超时

M. *_*ico 1 java amazon-web-services amazon-dynamodb aws-lambda

我在 Amazon 的 Lambda 服务上上传了以下 Java 类:

public class DevicePutHandler implements RequestHandler<DeviceRequest, Device> {
    private static final Logger log = Logger.getLogger(DevicePutHandler.class);

    public Device handleRequest(DeviceRequest request, Context context) {
        AmazonDynamoDB client = AmazonDynamoDBClientBuilder.defaultClient();
        DynamoDBMapper mapper = new DynamoDBMapper(client);

        if (request == null) {
            log.info("The request had a value of null.");
            return null;
        }

        log.info("Retrieving device");
        Device deviceRetrieved = mapper.load(Device.class, request.getDeviceId());

        log.info("Updating device properties");
        deviceRetrieved.setBuilding(request.getBuilding());
        deviceRetrieved.setMotionPresent(request.getMotionPresent());
        mapper.save(deviceRetrieved);

        log.info("Updated device has been saved");
        return deviceRetrieved;
    }
}
Run Code Online (Sandbox Code Playgroud)

我还有一个执行角色集,可以让我完全控制 DynamoDB。我的权限应该完全没有问题,因为我以这种完全相同的方式对使用 Lambda 和 DynamoDB 的其他项目使用了完全相同的权限(唯一的区别是不同的请求类型)。

这个类的目的是让它被 API Gateway (API Gateway -> Lambda -> DynamoDB) 调用,但现在我只是想在 Lambda (Lambda -> DynamoDB) 上测试它。

作为参考,以防万一,这里是 DeviceRequest 类:

@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonPropertyOrder({ "deviceId", "building", "motionPresent" })
public class DeviceRequest {

   @JsonProperty("deviceId")
   private String deviceId;
   @JsonProperty("building")
   private String building;
   @JsonProperty("motionPresent")
   private Boolean motionPresent;
   @JsonIgnore
   private Map<String, Object> additionalProperties = new HashMap<String, Object>();

   @JsonProperty("deviceId")
   public String getDeviceId() {
       return deviceId;
   }

   @JsonProperty("deviceId")
   public void setDeviceId(String deviceId) {
       this.deviceId = deviceId;
   }

   @JsonProperty("building")
   public String getBuilding() {
       return building;
   }

    @JsonProperty("building")
    public void setBuilding(String building) {
        this.building = building;
    }

    @JsonProperty("motionPresent")
    public Boolean getMotionPresent() {
        return motionPresent;
    }

    @JsonProperty("motionPresent")
        public void setMotionPresent(Boolean motionPresent) {
        this.motionPresent = motionPresent;
    }

    @JsonAnyGetter
    public Map<String, Object> getAdditionalProperties() {
        return this.additionalProperties;
    }

    @JsonAnySetter
    public void setAdditionalProperty(String name, Object value) {
        this.additionalProperties.put(name, value);
    }

}
Run Code Online (Sandbox Code Playgroud)

这是设备类:

@DynamoDBTable(tableName="DeviceTable")
public class Device {
    private String deviceID;
    private String building;
    private String queue;
    private boolean motionPresent;

    @DynamoDBHashKey(attributeName="Device ID")
    public String getDeviceID() {
        return deviceID;
    }

    public void setDeviceID(String deviceID) {
        this.deviceID = deviceID;
    }

    @DynamoDBAttribute(attributeName="Motion Present")
    public boolean getMotionPresent() {
        return motionPresent;
    }

    public void setMotionPresent(boolean motionPresent) {
        this.motionPresent = motionPresent;
    }

    @DynamoDBAttribute(attributeName="Building")
    public String getBuilding() {
        return this.building;
    }

    public void setBuilding(String building) {
        this.building = building;
    }

    @DynamoDBAttribute(attributeName="Queue")
    public String getQueue() {
        return this.queue;
    }

    public void setQueue(String queue) {
        this.queue = queue;
    }
}
Run Code Online (Sandbox Code Playgroud)

这是我试图用以下方法测试 Lambda 的 JSON 输入:

{
  "deviceId": "test_device_name",
  "building": "building1",
  "motionPresent": false
}
Run Code Online (Sandbox Code Playgroud)

没有任何异常被抛出(我已经尝试将它包裹在一个 try/catch 块中)并且 lambda 超时是唯一发生的事情。我已经尝试在 DynamoDB 客户端初始化之前的一开始使用 log/print 语句来查看是否可以正确读取请求,并且它似乎可以正确解析 JSON 字段。我还把客户端构建器分离出来,发现构建器对象是可以初始化的,但是超时是从构建器调用 build() 来创建客户端的时候出现的。

如果有人对这种超时发生的原因有任何了解,请告诉我!

M. *_*ico 5

事实证明,通过增加超时时间和分配的内存,问题得到解决。不知道为什么它会起作用,因为 lambda 总是表示它的内存使用量低于先前设置的限制,但是很好。希望将来亚马逊能提供更好的错误反馈,指示 lambda 是否需要更多资源来运行。