Spring Cloud Function GET函数部署AWS Lambda遇参数类型不匹配错误

问题场景 #

原本基于已废弃的SpringBootRequestHandler实现了POST接口，本地及Lambda部署均正常。现改为带可选查询参数的GET接口，本地测试正常，但部署至AWS Lambda后，调用时出现argument type mismatch错误。

原有POST实现代码 #

端点接口 #

@SuppressWarnings("hiding")
@FunctionalInterface
public interface Demoapi<DemoRequest, DemoResponse> {
    @PostMapping(value = "/v1/demo")
    public ResponseEntity<DemoResponse> demo(@RequestBody DemoRequest demoInfo);
}

控制器实现 #

@RestController
public class Democontroller implements Demoapi<DemoRequest, DemoResponse> {
    static final Logger LOGGER = LogManager.getLogger(Democontroller.class);

    @Autowired
    private DemoService demoService;

    @Override
    public ResponseEntity<DemoResponse> demo(@RequestBody DemoRequest demoInfo) {
        DemoResponse demoResponse = new DemoResponse();
        try {
            demoResponse = demoService.demofun(demoInfo); // 业务逻辑
        }
        // 省略异常处理及返回逻辑
    }
}

修改后的GET实现代码 #

端点接口 #

@SuppressWarnings("hiding")
@FunctionalInterface
public interface Demoapi<Void, DemoResponse> { 
    // GET请求无请求体
    @GetMapping(value = "/v1/demo")
    public ResponseEntity<DemoResponse> demo(@RequestParam(name="q", required = false, defaultValue="...") String name);
    // 带可选查询参数q
}

控制器实现 #

@RestController
public class Democontroller implements Demoapi<Void, DemoResponse> {
    static final Logger LOGGER = LogManager.getLogger(Democontroller.class);

    @Autowired
    private DemoService demoService;

    @Override
    public ResponseEntity<DemoResponse> demo(@RequestParam(name="q", required = false , defaultValue="...") String name) {
        DemoResponse demoResponse=new DemoResponse();
        try {
            demoResponse = demoService.demofun(name); // 业务逻辑
        }
        // 省略异常处理及返回逻辑
    }
}

报错信息 #

2023-02-17 11:24:04.080  INFO 10 --- [           main] lambdainternal.AWSLambda                 : Started AWSLambda in 2.649 seconds (JVM running for 3.349)
2023-02-17 11:24:04.329 ERROR 10 --- [           main] c.f.c.c.BeanFactoryAwareFunctionRegistry : Failed to invoke function 'domainController'
java.lang.IllegalArgumentException: argument type mismatch

解决方案 #

核心原因 #

AWS Lambda中，Spring Cloud Function的适配器会将API Gateway的请求封装为APIGatewayProxyRequestEvent对象传递给函数，而控制器方法期望接收String类型的查询参数，导致类型不匹配。本地测试时是通过Spring MVC直接处理HTTP请求，参数解析逻辑不同，因此本地正常。

具体修复步骤 #

1. 调整控制器方法参数类型，改为接收APIGatewayProxyRequestEvent，从中提取查询参数：

@Override
public ResponseEntity<DemoResponse> demo(APIGatewayProxyRequestEvent event) {
    String name = event.getQueryStringParameters().getOrDefault("q", "...");
    DemoResponse demoResponse = new DemoResponse();
    try {
        demoResponse = demoService.demofun(name);
    }
    // 省略后续逻辑
}

同时调整接口定义的泛型和方法参数：

@FunctionalInterface
public interface Demoapi<APIGatewayProxyRequestEvent, DemoResponse> {
    @GetMapping(value = "/v1/demo")
    public ResponseEntity<DemoResponse> demo(APIGatewayProxyRequestEvent event);
}

2. 确保依赖正确，确认spring-cloud-function-adapter-aws依赖已引入，版本与Spring Cloud版本匹配。

3. 检查Lambda配置：

   • Handler设置为org.springframework.cloud.function.adapter.aws.FunctionInvoker（无需自定义DemoHandler，除非你在自定义Handler中已正确处理参数转换）
   • FUNCTION_NAME环境变量设置为demoController（确保对应的Spring Bean名称正确，注意大小写）

替代方案：使用Spring Cloud Function原生函数方式 #

若不想依赖Spring MVC控制器模式，可直接定义函数Bean，让Spring Cloud Function自动适配：

@Component
public class DemoFunction implements Function<APIGatewayProxyRequestEvent, DemoResponse> {
    @Autowired
    private DemoService demoService;

    @Override
    public DemoResponse apply(APIGatewayProxyRequestEvent event) {
        String name = event.getQueryStringParameters().getOrDefault("q", "...");
        return demoService.demofun(name);
    }
}

此时Lambda的FUNCTION_NAME环境变量设置为demoFunction，Handler使用org.springframework.cloud.function.adapter.aws.FunctionInvoker即可。

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