kinesis_put_record: Write a record to a Kinesis Stream

In AWR.Kinesis: Amazon 'Kinesis' Consumer Application for Stream Processing

Write a record to a Kinesis Stream

Description

Write a record to a Kinesis Stream

Usage

kinesis_put_record(stream, region = "us-west-1", data, partitionKey)

Arguments

stream	stream name (string)
region	AWS region (string)
data	data blog (string)
partitionKey	determines which shard in the stream the data record is assigned to, eg username, stock symbol etc (string)

Value

invisible list including the shard id and sequence number

References

https://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/model/PutRecordRequest.html

Examples

## Not run: 
df <- mtcars[1, ]
str(kinesis_put_record('test-AWR', data = jsonlite::toJSON(df), partitionKey = row.names(df)))

## End(Not run)

AWR.Kinesis documentation built on Aug. 19, 2023, 1:07 a.m.