Kinesis Data Streamsクライアント

dependencies {
    implementation("com.amplifyframework:aws-kinesis:LATEST_VERSION")
}

import com.amplifyframework.kinesis.AmplifyKinesisClient

val kinesis = AmplifyKinesisClient(
    context = applicationContext,
    region = "us-east-1",
    credentialsProvider = credentialsProvider
)

import com.amplifyframework.kinesis.AmplifyKinesisClient
import com.amplifyframework.kinesis.AmplifyKinesisClientOptions
import com.amplifyframework.recordcache.FlushStrategy
import kotlin.time.Duration.Companion.seconds

val kinesis = AmplifyKinesisClient(
    context = applicationContext,
    region = "us-east-1",
    credentialsProvider = credentialsProvider,
    options = AmplifyKinesisClientOptions {
        cacheMaxBytes = 10L * 1024 * 1024  // 10 MB
        maxRetries = 3
        flushStrategy = FlushStrategy.Interval(60.seconds)
        configureClient {
            retryStrategy { maxAttempts = 10 }
        }
    }
)

options = AmplifyKinesisClientOptions {
    flushStrategy = FlushStrategy.None
}

val result = kinesis.record(
    data = "Hello Kinesis".toByteArray(),
    partitionKey = "partition-1",
    streamName = "my-stream"
)
when (result) {
    is Result.Success -> { /* 正常に記録されました */ }
    is Result.Failure -> { /* エラーを処理します */ }
}

when (val result = kinesis.flush()) {
    is Result.Success -> println("${result.data.recordsFlushed}件のレコードをフラッシュしました")
    is Result.Failure -> println("フラッシュエラー: ${result.error}")
}

kinesis.clearCache()

kinesis.disable()
// レコードは無視され、自動フラッシュは一時停止されます

kinesis.enable()
// コレクションと自動フラッシュが再開されます

val sdkClient = kinesis.kinesisClient
// sdkClientを直接Kinesis APIコールに使用します

when (val result = kinesis.record(...)) {
    is Result.Success -> { /* 成功 */ }
    is Result.Failure -> when (result.error) {
        is AmplifyKinesisValidationException -> { /* 無効な入力 */ }
        is AmplifyKinesisLimitExceededException -> { /* キャッシュ満杯 */ }
        is AmplifyKinesisStorageException -> { /* データベースエラー */ }
        is AmplifyKinesisUnknownException -> { /* 予期しないエラー */ }
    }
}