ページ分割

多くの AWS オペレーションは、ペイロードが大きすぎて 1 回のレスポンスで返せない場合にページ分割された結果を返します。 AWS SDK for Kotlin には、結果を自動的にページ分割するサービスクライアントインターフェイスの拡張機能が含まれています。結果を処理するコードを記述するだけで済みます。

ページ分割は Flow<T> として公開されるため、非同期コレクション (map、、 など) に対して Kotlin のイディオマティック変換を活用できますfiltertake。例外は透過的であるため、エラー処理は通常の API コールのように感じられ、キャンセルはコルーチンの一般的な協調的なキャンセルに従います。詳細については、公式ガイドのhttps://kotlinlang.org/docs/flow.html「フローとフロー例外」を参照してください。

次のコード例は、listObjectsV2Paginated 関数呼び出しからのページ分割されたレスポンスを処理する方法を示しています。

インポート

import aws.sdk.kotlin.services.s3.S3Client
import aws.sdk.kotlin.services.s3.paginators.listObjectsV2Paginated
import kotlinx.coroutines.flow.*

コード

val s3 = S3Client.fromEnvironment()
val req = ListObjectsV2Request {
    bucket = "<my-bucket>"
    maxKeys = 1
}

s3.listObjectsV2Paginated(req)  // Flow<ListObjectsV2Response>
    .transform { it.contents?.forEach { obj -> emit(obj) } }
    .collect { obj ->
        println("key: ${obj.key}; size: ${obj.size}")
    }