AWS SDK v2中，如何使用S3 Client执行SelectObjectContent查询？

我的Gradle配置如下：

implementation(platform("software.amazon.awssdk:bom:2.18.25"))
implementation("software.amazon.awssdk:s3")
implementation("software.amazon.awssdk:url-connection-client")

对应的S3客户端初始化代码：

S3Client client = S3Client.builder()
        .region(Region.of("eu-west-1"))
        .credentialsProvider(StaticCredentialsProvider.create(AwsBasicCredentials.create("xxxxxxxx", "xxxxxxx")))
        .httpClient(UrlConnectionHttpClient.builder().buildWithDefaults(
                AttributeMap.builder().put(TRUST_ALL_CERTIFICATES, Boolean.TRUE).build()))
        .build();

我尝试构造S3 Select查询请求：

SelectObjectContentRequest request = SelectObjectContentRequest.builder()
        .bucket(bucket)
        .key(key)
        .expression(query)
        .expressionType(ExpressionType.SQL)
        .build();

但遇到问题：使用上述S3Client时，找不到可接收SelectObjectContentRequest的方法。我是否需要更换为AmazonS3ClientBuilder创建的AmazonS3客户端？我使用的是AWS SDK v2版本。

不需要更换客户端，AWS SDK v2中S3Client完全支持S3 Select功能，问题出在方法调用错误和请求参数不全：

1. 调用正确的方法：S3Client中处理SelectObjectContentRequest的对应方法是selectObjectContent()，示例调用如下：

try (SelectObjectContentResponse response = client.selectObjectContent(request)) {
    // 遍历响应事件流处理结果
    for (SelectObjectContentEvent event : response.events()) {
        if (event instanceof RecordsEvent) {
            RecordsEvent records = (RecordsEvent) event;
            // 处理返回的记录数据
            System.out.println(records.payload().asUtf8String());
        }
    }
}

2. 补充必填请求参数：你的SelectObjectContentRequest缺少两个必填配置：inputSerialization和outputSerialization，必须指定源对象的格式（如CSV、JSON）和输出格式，否则请求会失败。完整请求构建示例：

SelectObjectContentRequest request = SelectObjectContentRequest.builder()
        .bucket(bucket)
        .key(key)
        .expression(query)
        .expressionType(ExpressionType.SQL)
        .inputSerialization(InputSerialization.builder()
                .csv(CSVInput.builder().fileHeaderInfo(FileHeaderInfo.USE).build())
                .build())
        .outputSerialization(OutputSerialization.builder()
                .csv(CSVOutput.builder().build())
                .build())
        .build();

注：AmazonS3ClientBuilder是AWS SDK v1的客户端构建方式，与v2不兼容，你当前使用的S3Client是v2的标准客户端，无需切换。

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