[AWS] Athena

Athena는 Amazon S3(Simple Storage Service)에서 표준 SQL을 사용하여 데이터를 쉽게 바로 분석할 수 있는 대화형 쿼리 서비스라고 합니다.

Amazon S3에 저장된 데이터에서 Athena를 가리키고, 표준 SQL을 사용하여 임시 쿼리를 실행하고 몇 초 안에 결과를 얻을 수 있습니다.

쉽게 말하면, Amazon S3 스토리지에 저장된 다양한 포맷의 기초 데이터(csv, tsv, txt, CRC, Parquet 형식의 데이터들)에 대해 바로 표준 SQL문을 사용해 데이터를 검색 및 분석할 수 있는 서비스입니다.

 

 

Spring 사용 예

 

https://github.com/contactsunny/AmazonAthenaSpringBootPOC/blob/master/src/main/java/com/contactsunny/poc/SpringBootAmazonAthenaPOC/App.java

GitHub - contactsunny/AmazonAthenaSpringBootPOC: This is a simple Spring Boot POC to demonstrate how we can query an Amazon Athe

 

    private static String submitAthenaQuery(AthenaClient athenaClient) {

        QueryExecutionContext queryExecutionContext = QueryExecutionContext.builder()
                .database(ATHENA_DATABASE).build();

        ResultConfiguration resultConfiguration = ResultConfiguration.builder()
                .outputLocation(ATHENA_OUTPUT_S3_FOLDER_PATH).build();

        StartQueryExecutionRequest startQueryExecutionRequest = StartQueryExecutionRequest.builder()
                .queryString(SIMPLE_ATHENA_QUERY)
                .queryExecutionContext(queryExecutionContext)
                .resultConfiguration(resultConfiguration).build();

        StartQueryExecutionResponse startQueryExecutionResponse = athenaClient.startQueryExecution(startQueryExecutionRequest);

        return startQueryExecutionResponse.queryExecutionId();
    }