sagemakerfeaturestoreruntime/aws.sdk.kotlin.services.sagemakerfeaturestoreruntime/SageMakerFeatureStoreRuntimeClient/batchWriteRecord

batchWriteRecord

abstract suspend fun batchWriteRecord(input: BatchWriteRecordRequest): BatchWriteRecordResponse

Writes a batch of Records to one or more FeatureGroups. Use this API for bulk ingestion of records into the OnlineStore and OfflineStore.

You can set the ingested records to expire at a given time to live (TTL) duration after the record's event time by specifying the TtlDuration parameter. A request level TtlDuration applies to all entries that do not specify their own TtlDuration.

Samples

// Write records to multiple feature groups
val resp = sageMakerFeatureStoreRuntimeClient.batchWriteRecord {
    entries = listOf<BatchWriteRecordEntry>(
        BatchWriteRecordEntry {
            featureGroupName = "my-feature-group"
            record = listOf<FeatureValue>(
                FeatureValue {
                    featureName = "customer_id"
                    valueAsString = "cust-001"
                },
                FeatureValue {
                    featureName = "age"
                    valueAsString = "25"
                }                    
            )
        }            
    )
}