kinesis_get_records: Get record from a Kinesis Stream
In daroczig/AWR.Kinesis: Amazon 'Kinesis' Consumer Application for Stream Processing
Description
Usage
Arguments
Value
Note
References
Description
Get record from a Kinesis Stream
Usage
1
2
3
4
kinesis_get_records(stream, region = "us-west-1", limit = 25, shard_id,
iterator_type = c("TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER",
"AFTER_SEQUENCE_NUMBER", "AT_TIMESTAMP"), start_sequence_number,
start_timestamp)
Arguments
stream
stream name (string)
region
AWS region (string)
limit
number of records to fetch
shard_id
optional shard id - will pick a random active shard if left empty
iterator_type
shard iterator type
start_sequence_number
for AT_SEQUENCE_NUMBER and AFTER_SEQUENCE_NUMBER iterators
start_timestamp
for AT_TIMESTAMP iterator
Value
character vector that you might want to post-process eg with jsonlite::stream_in
Note
Use this no more than getting sample data from a stream - it's not intended for prod usage.
References
daroczig/AWR.Kinesis documentation built on May 14, 2019, 12:44 p.m.
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
Description Usage Arguments Value Note References
Description
Get record from a Kinesis Stream
Usage
1 2 3 4 | kinesis_get_records(stream, region = "us-west-1", limit = 25, shard_id,
iterator_type = c("TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER",
"AFTER_SEQUENCE_NUMBER", "AT_TIMESTAMP"), start_sequence_number,
start_timestamp)
|
Arguments
stream |
stream name (string) |
region |
AWS region (string) |
limit |
number of records to fetch |
shard_id |
optional shard id - will pick a random active shard if left empty |
iterator_type |
shard iterator type |
start_sequence_number |
for |
start_timestamp |
for |
Value
character vector that you might want to post-process eg with jsonlite::stream_in
Note
Use this no more than getting sample data from a stream - it's not intended for prod usage.
References
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
Embedding an R snippet on your website
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.