SpringCloudFunction处理SQSEvent异常：经FunctionInvoker传入Lambda的事件为空

通过FunctionInvoker传递给Lambda的SQSEvent请求被转换为空对象。日志显示AWSLambdaUtil类已打印输入内容，但请求到达Lambda函数时变为空对象。测试代码如下：

System.setProperty("MAIN_CLASS", MyApplication.class.getName());
System.setProperty("spring.cloud.function.definition", "SQSEventHandler");
String jsonEventPayload = Files.readString(ResourceUtils.getFile("classpath:sqs-event/sqsEvent.json").toPath());

SQSEvent event = objectMapper.readValue(jsonEventPayload,SQSEvent.class);

InputStream targetStream = new ByteArrayInputStream(objectMapper.writeValueAsBytes(event));
ByteArrayOutputStream output = new ByteArrayOutputStream();
FunctionInvoker invoker = new FunctionInvoker();
invoker.handleRequest(targetStream, output, null);

可能的原因及解决步骤 #

• 避免重复序列化/反序列化操作
  测试代码中先将JSON字符串反序列化为SQSEvent对象，再重新序列化为字节流，这个过程可能丢失Lambda事件所需的原始结构（比如某些Jackson注解处理的字段）。直接使用原始JSON字符串作为输入流：

  String jsonEventPayload = Files.readString(ResourceUtils.getFile("classpath:sqs-event/sqsEvent.json").toPath());
  InputStream targetStream = new ByteArrayInputStream(jsonEventPayload.getBytes(StandardCharsets.UTF_8));
  

• 确保事件类型依赖与配置正确
  检查是否引入了正确的AWS Lambda事件依赖，版本需与Spring Cloud Function适配：

  <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-lambda-java-events</artifactId>
      <version>3.11.0</version> <!-- 使用匹配项目的版本 -->
  </dependency>
  

  同时在函数Bean中显式指定输入类型，避免类型推断错误：

  @Bean
  public Function<SQSEvent, String> SQSEventHandler() {
      return event -> {
          // 业务处理逻辑
          return "处理完成";
      };
  }
  

• 完善FunctionInvoker的上下文初始化
  测试代码中未显式关联Spring上下文，可能导致FunctionInvoker无法正确识别函数定义。手动初始化Spring上下文后再调用：

  SpringApplication application = new SpringApplication(MyApplication.class);
  ConfigurableApplicationContext context = application.run();
  
  FunctionInvoker invoker = new FunctionInvoker();
  invoker.setApplicationContext(context);
  invoker.handleRequest(targetStream, output, null);
  

• 开启DEBUG日志追踪转换流程
  在application.properties中添加日志配置，查看事件转换过程中的细节：

  logging.level.org.springframework.cloud.function.adapter.aws=DEBUG
  logging.level.com.amazonaws.services.lambda.runtime=DEBUG
  

  重点关注是否有反序列化异常、字段不匹配等日志信息，定位空对象产生的具体环节。

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