集成AWS API Gateway与SQS：payload超256KB的处理及转存S3咨询

我来给你拆解这个问题，刚好之前做过类似的集成场景，踩过不少坑：

一、Payload超过256KB时会发生什么？ #

直接通过API Gateway集成SQS的话，一定会触发报错——因为SQS单条消息的大小上限就是256KB（准确说是262,144字节）。这时候API Gateway会直接返回400 Bad Request，错误信息大概是Invalid request body: message size exceeds 256KB，请求根本到不了SQS，直接在网关层就被拦截了。

二、如何实现大Payload转存S3？ #

要解决这个问题，得引入Lambda作为中间层来做中转，具体流程和配置步骤如下：

• 第一步：调整API Gateway的payload上限
  API Gateway本身支持最大10MB的请求体（不管是REST API还是HTTP API），先在你的API Gateway设置里，把「Maximum payload size」调到你需要的上限（比如10MB），确保大请求能进入后续流程。

• 第二步：用Lambda做中转处理
  把API Gateway的集成目标从SQS改成Lambda，Lambda的逻辑分为两种情况：

  • 如果请求payload小于256KB：直接调用SQS的SendMessage接口，把原消息发送到队列；
  • 如果请求payload大于256KB：先把payload上传到指定的S3桶（建议用UUID或请求ID作为S3对象的键名，避免重复覆盖），然后生成一条包含S3对象路径、文件大小、请求ID等元数据的消息，再把这条元数据消息发送到SQS。

• 第三步：配置必要的权限
  给Lambda角色添加两个关键权限：

  1. S3的PutObject权限，允许它上传文件到目标桶；
  2. SQS的SendMessage权限，允许它往队列发消息；
     同时要确保API Gateway有调用这个Lambda的权限（可以通过API Gateway的集成配置自动生成，或者手动添加IAM策略）。

• 第四步：下游服务适配处理
  消费SQS消息的下游服务，需要先判断消息内容是原payload还是S3元数据：

  • 如果是原payload，直接处理；
  • 如果是元数据，就根据S3路径去下载对应的文件，处理完成后可以根据需求删除S3文件（或者设置S3生命周期规则自动过期清理）。

额外优化建议 #

• 可以在Lambda里添加payload大小的校验逻辑，避免不必要的S3上传操作；
• 如果担心Lambda执行超时（比如超大文件上传），可以考虑用API Gateway的异步调用模式，或者把S3上传逻辑优化成分段上传；
• 给S3桶开启服务器端加密，保障大payload的安全性。

内容的提问来源于stack exchange，提问作者kranthi117