如何将Spring Boot模型中的数据作为CVS文件存储到S3中

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-java-sdk-s3</artifactId>
</dependency>

import org.apache.commons.csv.CSVFormat;
import org.apache.commons.csv.CSVPrinter;
import org.springframework.stereotype.Component;

import java.io.FileWriter;
import java.io.IOException;
import java.util.List;

@Component
public class CsvWriter {

    public void writeUsersToCsv(List<User> users, String filePath) throws IOException {
        FileWriter fileWriter = new FileWriter(filePath);
        CSVPrinter csvPrinter = new CSVPrinter(fileWriter, CSVFormat.DEFAULT.withHeader("Id", "Name", "Email"));

        for (User user : users) {
            csvPrinter.printRecord(user.getId(), user.getName(), user.getEmail());
        }

        csvPrinter.flush();
        csvPrinter.close();
        fileWriter.close();
    }
}

import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.model.PutObjectRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.File;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;

@RestController
public class UserController {

    private final CsvWriter csvWriter;
    private final AmazonS3 amazonS3;
    private final String bucketName = "your-bucket-name"; // 替换为你的S3存储桶名称

    @Autowired
    public UserController(CsvWriter csvWriter, AmazonS3 amazonS3) {
        this.csvWriter = csvWriter;
        this.amazonS3 = amazonS3;
    }

    @GetMapping("/users/export")
    public String exportUsers() {
        List<User> users = Arrays.asList(
                new User(1, "John Doe", "john@example.com"),
                new User(2, "Jane Smith", "jane@example.com"),
                new User(3, "Tom Brown", "tom@example.com")
        );

        try {
            String filePath = "users.csv";
            csvWriter.writeUsersToCsv(users, filePath);

            File file = new File(filePath);
            PutObjectRequest request = new PutObjectRequest(bucketName, filePath, file);
            amazonS3.putObject(request);

            file.delete(); // 删除本地的CSV文件

            return "CSV文件已成功导出并上传至S3！";
        } catch (IOException e) {
            e.printStackTrace();
            return "导出CSV文件时发生错误！";
        }
    }
}