Gets data records from a Kinesis data stream's shard — kinesis_get_records • botor

Gets data records from a Kinesis data stream's shard

kinesis_get_records(shard_iterator, limit = 25L)

Arguments

shard_iterator: the position in the shard from which you want to start sequentially reading data records, usually provided by kinesis_get_shard_iterator
limit: maximum number of records to return

Value

list of Records, NextShardIterator and MillisBehindLatest

References

https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/kinesis.html#Kinesis.Client.get_records

Examples

if (FALSE) { # \dontrun{
botor(profile_name = 'botor-tester')
iterator <- kinesis_get_shard_iterator(stream = 'botor-tester', shard = '0')
kinesis_get_records(iterator$ShardIterator)
} # }