코루틴을 지원하는 새로운 Kotlin용 AWS SDK

Jessie Cho

Read this post in other languages:

• English
,
• 简体中文

새로운 Kotlin용 AWS SDK가 2021년 12월 AWS re:Invent에서 발표되었습니다. 이 SDK를 사용하면 Amazon S3, Amazon EC2, DynamoDB 등과 함께 작동하는 Kotlin 애플리케이션을 빌드할 수 있습니다. 이 SDK는 현재 테스트 중이며 곧 안정화 버전으로 제공될 예정입니다.

이 SDK는 처음부터 Kotlin 언어 및 모범 사례를 지원하도록 설계되어 Kotlin 개발자에게 익숙하고 관례적인 AWS 상호작용 경험을 제공합니다. 이 SDK는 비동기 구현을 위해 Kotlin 코루틴을 활용하며 Kotlin 멀티플랫폼 프로젝트와 호환되도록 할 계획입니다.

Kotlin 프로그램에서 새 SDK를 사용하려면 프로젝트에 해당 종속 요소를 추가해야 합니다. 예를 들어 DynamoDB와 통신하려면 aws.sdk.kotlin:dynamodb 모듈이 필요합니다.

repositories {
    mavenCentral()
}

dependencies {
    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.0")
    
    // The following line adds a dependency on the dynamodb client.
    // For demonstration purposes, we use 0.+ to get the latest version
    implementation("aws.sdk.kotlin:dynamodb:0.+")
}

지원되는 모듈의 전체 목록은 AWS SDK 문서에서 확인할 수 있습니다.

종속 요소를 다운로드하면 API를 사용할 수 있습니다.

import kotlinx.coroutines.runBlocking
import aws.sdk.kotlin.services.dynamodb.DynamoDbClient
//sampleStart 
fun main() = runBlocking {
    val client = DynamoDbClient { region = "us-east-2" }
    val resp = client.listTables { limit = 10 }

    println("Current DynamoDB tables: ")
    resp.tableNames?.forEach { println(it) }

    client.close()
}
//sampleEnd 

이 프로그램은 단순히 테이블 목록을 검색하고 테이블 이름을 표준 출력으로 인쇄합니다. 위의 예시에서 listTables는 일시 중지 함수이므로 코드는 runBlocking 호출로 래핑됩니다.

페이지 지정된 액세스, 동시 흐름 및 바이트 스트리밍 응답을 아울러 모든 S3 객체를 하나의 버킷에 담아 로컬 임시 디렉터리로 다운로드하는 방법을 보여주는 약간 더 복잡한 예시는 어떨까요?

import aws.sdk.kotlin.services.s3.S3Client
import aws.sdk.kotlin.services.s3.model.GetObjectRequest
import aws.sdk.kotlin.services.s3.model.ListObjectsV2Request
import aws.sdk.kotlin.services.s3.paginators.listObjectsV2Paginated
import aws.smithy.kotlin.runtime.content.writeToFile
import kotlinx.coroutines.flow.asFlow
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.flatMapConcat
import kotlinx.coroutines.flow.flowOf
import java.nio.file.Paths
import kotlin.io.path.createDirectories
//sampleStart 
suspend fun downloadAllS3Objects(bucketName: String) {
   val s3 = S3Client.fromEnvironment()
   val listReq = ListObjectsV2Request {
       bucket = bucketName
   }
   s3.listObjectsV2Paginated(listReq)
       .flatMapConcat { it.contents?.asFlow() ?: flowOf() }
       .filter { it.size > 0 }
       .collect { obj ->                     
           val getReq = GetObjectRequest {
               bucket = bucketName
               key = obj.key
           }
           s3.getObject(getReq) {
               val path = Paths.get(System.getProperty("java.io.tmpdir"), obj.key)
               path.parent.createDirectories()
               it.body?.writeToFile(path)
           }
       }
}
//sampleEnd

위의 예시에서는 SDK의 일시 중지 함수의 용례를 다시 한 번 확인할 수 있습니다. 여기서 getObject 및 writeToFile 함수는 모두 suspend 키워드로 표시되어 있습니다.

새로운 Kotlin용 AWS SDK의 공식 문서에서 시작하는 방법에 대한 자세한 단계별 지침을 찾을 수 있습니다. 또한 Amazon DynamoDB, S3, Rekognition, Amazon Simple Notification Service 및 AWS Key Management Service와 같은 여러 AWS 서비스에서 API의 사용을 보여주는 흥미로운 예시도 많이 찾아볼 수 있습니다.

새로운 Kotlin용 AWS SDK는 현재 개발 중이며 로드맵에서 어떤 기능들이 계획되어 있는지 확인할 수 있습니다. 지금 사용해 보고 의견을 공유해 주세요!

게시물 원문 작성자

Anton Arhipov

Subscribe to Kotlin Blog updates

Subscribe form

By submitting this form, I agree to the JetBrains Privacy Policy Notification icon

이 양식을 제출함으로써 본인은 JetBrains s.r.o.("JetBrains"가 본인의 이름, 이메일 주소 및 위치 데이터를 사용하여 상업적 커뮤니케이션을 포함한 뉴스레터를 보내고 이러한 목적으로 개인 데이터를 처리할 수 있음에 동의합니다. 본인은 JetBrains가 JetBrains 개인정보보호정책에 따라 이러한 목적으로 제3자 서비스를 사용하여 해당 데이터를 처리할 수 있음에 동의합니다. 본인은 내 프로필에서 언제든지 이 동의를 철회할 수 있음을 이해합니다. 또한 각 이메일에는 수신 거부 링크가 포함됩니다.

Submit

감사합니다!