Kinesis Data Streamsクライアント

import AmplifyKinesisClient

let kinesis = try AmplifyKinesisClient(
    region: "us-east-1",
    credentialsProvider: credentialsProvider
)

let kinesis = try AmplifyKinesisClient(
    region: "us-east-1",
    credentialsProvider: credentialsProvider,
    options: .init(
        cacheMaxBytes: 10 * 1_024 * 1_024,  // 10 MB
        maxRetries: 3,
        flushStrategy: .interval(60),
        configureClient: { config in
            // 基盤となるKinesisClientConfigurationをカスタマイズする
        }
    )
)

options: .init(flushStrategy: .none)

let result = try await kinesis.record(
    data: "Hello Kinesis".data(using: .utf8)!,
    partitionKey: "partition-1",
    streamName: "my-stream"
)

let flushResult = try await kinesis.flush()
print("\(flushResult.recordsFlushed)件のレコードをフラッシュしました")

let cleared = try await kinesis.clearCache()

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

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

let sdkClient = kinesis.getKinesisClient()
// sdkClientを直接Kinesis APIコールに使用します

do {
    try await kinesis.record(
        data: payload,
        partitionKey: "key",
        streamName: "stream"
    )
} catch let error as KinesisError {
    switch error {
    case .validation(let desc, _, _):
        print("検証エラー: \(desc)")
    case .cacheLimitExceeded:
        print("キャッシュ満杯")
    case .cache(let desc, _, _):
        print("ストレージエラー: \(desc)")
    case .unknown(let desc, _, _):
        print("不明なエラー: \(desc)")
    }
}