如何解决将 aws gateway api 与 Lambda java 函数集成并在它们之间传递 json 数据的最简单方法是什么?
我的目标是使用 aws api 网关构建一组 REST api,返回 java Lambda 函数和 DynamoDB。请求和响应的负载是 json。我想避免 json 和 java 之间以及 java 和 dynamodb 之间繁琐的字段级映射代码,因此我尝试使用 gson 将 json 映射到增强 dynamodb 客户端的 java 对象,以便我可以使用 java pojos 作为 dynamodb 查询的输入和输出。当单独测试功能时,这一切都很好。 我遇到的问题是在尝试将网关 api 集成到函数时在网关和 Lambda 之间传递 json。我已经尝试了 Lambda 函数的两个接口,RequestHandler 和 RequestStreamHandler。我可以每一个都做我需要的一半,但是使用 RequestHander 我在将响应主体返回为 json 时出现运行时错误,使用 RequestStreamHandler 我可以成功地将响应主体设置为 json,但是我在接收请求主体时遇到问题作为json。 似乎 aws 网关框架中的某些内容正在将主体 json 转换为转义字符串,然后框架的另一部分尝试将转义字符串转换为 json 并失败。
我正在尝试做的似乎是 aws 网关和 Lambda 的最基本的 REST api 用例,但除了琐碎的“hello world”类型之外,我在 aws 文档中找不到任何代码示例。 Aws 文档似乎也很单薄,所以有没有人使用 aws 网关和 Lambda 成功构建带有 json 有效负载的 REST api,他们可以分享成功的秘诀?
这里有一些我尝试过的背景:
API 网关: 我已经使用 Lambda 代理集成到我的 Lambda 函数创建了网关 api。我没有指定任何模型来验证输入。我刚刚采用了默认设置。我正在传递一个 json 对象作为我的 HTTP 请求的主体来测试 api。
Lambda 函数 使用 SDK 的 V2 用 java 编码。
RequestHandler 函数 - 我创建了一个类,该类实现了 RequestHandler 接口,将输入参数指定为 HashMap,输出为字符串。我已经成功地从哈希图中获得了 HTTP 请求的正文,并使用 Gson 将正文转换为我的 Java pojo。都好。 但是,我尝试将 json 包含为响应正文失败。我已经使用 Gson 和 org.json 来构建我的 http 响应并将 json 作为主体。我可以成功地对该功能进行单元测试,但是当与我的网关 api 集成时,我在网关中收到一个错误(不是响应已被转义):
UTC 2021 年 1 月 12 日星期二 11:12:23:转换前的端点响应主体:"{"body":{"message":"hello world"},"isBase64encoded":false,"statusCode": 200}" UTC 2021 年 1 月 12 日星期二 11:06:59:由于配置错误,执行失败:Lambda 代理响应格式错误
RequestStreamHandler handleRequest 方法的签名是:
public void handleRequest(InputStream input,OutputStream output,Context context)
在这种情况下,我可以使用 gson 成功创建一个 json 响应并将其写入输出流,并且 api 网关可以使用它。
但是我的输入有问题。我尝试使用 gson 来解析输入流并提取正文。这个没问题,但是body不是json,是转义的json字符串,例如:
"{\r\n "id": "10",\r\n "title": "滑雪之旅",\r\n "owner": "captain",\r\n " location": \r\n [\r\n {"latitude": 55,"longitude":-2 }\r\n ]\r\n}"
我无法使用 Gson 来解析它,也无法使用 Gson 将其转换为 pojo。如果我尝试,则会出现运行时异常。为了解决这个问题,我使用 org.apache.commons.text.StringEscapeUtils 删除转义字符,然后删除字符串周围的前导和尾随引号。然后我可以使用 Gson 将结果字符串转换为我的 pojo 类。这太乏味了。
我尝试更改用于 handleRequest 方法的输入和输出的类,例如返回一个 JsonObject 以查看是否更改了我收到的内容,但无济于事。如果 body 只包含一个字符串而不是 json,那么没有问题。因此,根据我发现的示例,只需返回“hello world”作为正文就可以了。
我一定遗漏了一些东西,可能在网关 api 的定义或 Lambda 函数的输入和输出参数的类型中,但没有文档,它真的只是在黑暗中徘徊。嘿,我想要做的就是从 rest 请求的主体中取出一个 json 对象并将其作为 json 文档写入 nosql 数据库,被转换和映射绊倒真的很令人沮丧。
感谢任何可以帮助我的人。
解决方法
假设这是我们的 Hander 类,其中 ApiGatewayRequest
和 ApiGatewayProxyResponse
是请求和响应类名称。
public class MyHandler implements RequestHandler<ApiGatewayRequest,ApiGatewayProxyResponse> {
@Override
public ApiGatewayProxyResponse handleRequest(ApiGatewayRequest request,Context context) {
}
}
请求类
public class ApiGatewayRequest {
private String body;
private Map<String,String> headers;
private Map<String,String> queryStringParameters;
private Map<String,String> pathParameters;
private boolean isBase64Encoded;
}
响应类
public class ApiGatewayProxyResponse {
private int statusCode;
private Map<String,String> headers;
private String body;
}
Json 字符串应该在 body
中使用 com.fasterxml.jackson.databind.ObjectMapper 发送,例如
String body = new ObjectMapper().writeValueAsString(ouputObject)
必要的标题,例如:Access-Control-Allow-Credentials
、Access-Control-Allow-Origin
或 Content-Type
我已经解决了我自己的问题。在 aws gateway 中,我选择了我的 api 类型为 Rest,这似乎是创建通过 HTTP 访问的 Rest 服务的明显选择。我创建了一个新的 Http 类型的 api 来与相同的 Lambda 函数集成并缩短解决问题的长话短说。传递给 Lambda 函数的我的 post 请求的正文不会被转义,可以作为 json 处理,同样,我的响应中的正文在返回到 http 客户端之前不会被转义或拒绝。然而,我是通过反复试验而不是遵循清晰的文档或工作示例发现的。我的下一步是实现get、post、put和delete HTTP方法的示例,以了解在路径变量和查询字符串的情况下如何传递参数,以及完成与dynamodb的集成。完成后我会发布我的工作代码。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。