java - 为 SpringCloudFunction 扩展 SpringBootStreamHandler

Question

我正在一个使用 Spring Cloud Function for AWS Lambda 的项目中工作。我注意到很少有关于扩展 SpringBootRequestHandler 以处理特定类型的输入和输出的示例。

但是，我的项目要求输入 json 对象是随机的。因此，我无法定义 Java 类，这是 SpringBootRequestHandler 实现所必需的。

目前，我扩展 SpringBootStreamHandler 的处理程序类如下所示：

public class CustomHandler extends SpringBootStreamHandler {

  @Autowired
  private BeanA beanA;

  @Override
  public void handleRequest(InputStream input, OutputStream output, Context context) throws IOException {
    // Call initialize to autowire beanA
    this.initialize(); 
    // Business logic to parse partial of json input into an object.
    ....
  }
}

但是，有没有一种方法可以将业务逻辑抽象到另一个类扩展 Function 类似于 SpringBootRequestHandler 实现？

@Component
public class CustomFunction extend Function<?,?> {
  // Business logic
  ........
}