AmazonLambda在尝试为DynamoDB初始化客户端时超时



我在亚马逊的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;
}
}

我还有一个执行角色集,它让我完全控制DynamoDB。我的权限应该很好,因为我在使用Lambda和DynamoDB的其他项目中使用了完全相同的权限(唯一的区别是不同的请求类型)。

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

作为参考,如果它很重要,这里是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);
}
}

这是设备类:

@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;
}
}

以下是我尝试使用的测试Lambda的JSON输入:

{
"deviceId": "test_device_name",
"building": "building1",
"motionPresent": false
}

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

如果有人知道为什么会发生这种超时,请告诉我!

事实证明,通过增加timout周期和分配的内存,问题得到了解决。不确定它为什么工作,因为lambda总是指示它的内存使用量低于之前设置的限制,但哦,好吧。希望将来亚马逊能提供更好的错误反馈,指示lambda是否需要更多的资源来运行。

最新更新