• 1. Service 클래스에 readObject 메서드 생성
• 2. Controller 클래스에서 해당 로직 실행
• 3. CSV파일 읽기 성공!

1. Service 클래스에 readObject 메서드 생성

과정

1.   S3Object의 getObjectContent()를 호출하여 S3ObjectInputStream형태로 CSV파일 데이터를 불러온다.    
2.   그 해당 CSV파일을 BufferedReader로 한 줄 씩 읽어와서 데이터를 읽었다.

     * CSV파일이 JSON에 비해 용량이 작아 사용했지만 읽어올 때 데이터 형태를 잘 짜지 않으면 받아오기 까다로울 것 같다.

@Service
@RequiredArgsConstructor
public class S3Service {

    private final AmazonS3 amazonS3;


    @Value("${aws.s3.bucket}")
    private String bucket;

    /**
     * S3 bucket 파일 읽기
     */
    public void readObject(String storedFileName) throws IOException{
        S3Object o = amazonS3.getObject(new GetObjectRequest(bucket, storedFileName));
        S3ObjectInputStream ois = null;
        BufferedReader br = null;

        // Read the CSV one line at a time and process it.
        try {
            ois = o.getObjectContent();
            System.out.println ("ois = " + ois);
            br = new BufferedReader (new InputStreamReader (ois, "UTF-8"));
            String line;
            while ((line = br.readLine()) != null) {
                // Store 1 record in an array separated by commas
                String[] data = line.split(",", 0);

                if(!data[0].equals("N")) {
                    int idx =Integer.parseInt(data[0]);
                    System.out.println(idx+"-----------------------------------");
                    for(int i=1; i<data.length; i++){
                        System.out.print(data[i]+" ");
                    }
                    System.out.println();
                }else{
                    for (String s : data) {
                        System.out.print(s+" ");
                    }
                    System.out.println();
                }

            }
        }finally {
            if(ois != null){
                ois.close();
            }
            if(br != null){
                br.close();
            }
        }
    }

}

참고로 내 CSV파일 데이터는 다음과 같다.

2. Controller 클래스에서 해당 로직 실행

@Controller
@RequiredArgsConstructor
public class S3Controller {

    private final S3Service downloadS3;

    @GetMapping("/csv_read")
    public String read() throws IOException {
        downloadS3.readObject("20210522.csv");
        return "csv_read"; // csv_read.html 있어야 에러 발생 안함 
    }
}

3. CSV파일 읽기 성공!

프로젝트를 실행하고 localhost:8080/csv_read를 하면 csv파일이 읽어진다.

그 전의 과정은 아래 링크 참고