Spring Cloud Function集成AWS Lambda与SQS：批量消息处理问题咨询

1. 调整Spring Cloud Function的输入类型 #

当前你的Function接收单个Message<String>，因此SQS批量消息会被拆分为单条触发。要实现批量处理，需将Function的输入类型改为List<Message<String>>，示例代码如下：

@Bean
public Function<List<Message<String>>, String> recBatchMsg() {
    return messages -> {
        messages.forEach(msg -> {
            System.out.println(msg.getPayload());
            System.out.println(msg.getHeaders());
        });
        return "Processed " + messages.size() + " messages";
    };
}

2. 配置SQS触发器的批量参数 #

在AWS控制台或SAM模板中，为Lambda的SQS触发器配置以下参数：

• 批量大小（Batch size）：设置每次触发Lambda时传递的最大消息数量（范围1-10000）
• 批量窗口（Batch window）：设置AWS收集消息的最长等待时间（最多300秒），达到批量大小或窗口超时后触发Lambda

3. 官方参考文档 #

• Spring Cloud Function AWS适配器文档：明确说明当Function的输入类型为集合（如List）时，会接收SQS的批量消息集合，无需额外配置适配器。
• AWS Lambda SQS触发器文档：详细解释批量处理的参数配置、消息重试、批量失败处理等核心逻辑。
• Spring Cloud AWS文档：涵盖SQS与Lambda集成的批量处理最佳实践，适配你使用的3.0.1版本特性。

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