将 aws gateway api 与 Lambda java 函数集成并在它们之间传递 json 数据的最简单方法是什么?

如何解决将 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 类,其中 ApiGatewayRequestApiGatewayProxyResponse 是请求和响应类名称。

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-CredentialsAccess-Control-Allow-OriginContent-Type

,

我已经解决了我自己的问题。在 aws gateway 中,我选择了我的 api 类型为 Rest,这似乎是创建通过 HTTP 访问的 Rest 服务的明显选择。我创建了一个新的 Http 类型的 api 来与相同的 Lambda 函数集成并缩短解决问题的长话短说。传递给 Lambda 函数的我的 post 请求的正文不会被转义,可以作为 json 处理,同样,我的响应中的正文在返回到 http 客户端之前不会被转义或拒绝。然而,我是通过反复试验而不是遵循清晰的文档或工作示例发现的。我的下一步是实现get、post、put和delete HTTP方法的示例,以了解在路径变量和查询字符串的情况下如何传递参数,以及完成与dynamodb的集成。完成后我会发布我的工作代码。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


依赖报错 idea导入项目后依赖报错,解决方案:https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错:更换其他版本 无法下载依赖可参考:https://blog.csdn.net/weixin_42628809/a
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
错误1:gradle项目控制台输出为乱码 # 解决方案:https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
错误还原:在查询的过程中,传入的workType为0时,该条件不起作用 &lt;select id=&quot;xxx&quot;&gt; SELECT di.id, di.name, di.work_type, di.updated... &lt;where&gt; &lt;if test=&qu
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
解决方案1 1、改项目中.idea/workspace.xml配置文件,增加dynamic.classpath参数 2、搜索PropertiesComponent,添加如下 &lt;property name=&quot;dynamic.classpath&quot; value=&quot;tru
删除根组件app.vue中的默认代码后报错:Module Error (from ./node_modules/eslint-loader/index.js): 解决方案:关闭ESlint代码检测,在项目根目录创建vue.config.js,在文件中添加 module.exports = { lin
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-