kinesis_put_record: Write a record to a Kinesis Stream

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

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

http://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)

daroczig/AWR.Kinesis documentation built on May 14, 2019, 12:44 p.m.