Retrieves the stream records from a given shard.
Specify a shard iterator using the ShardIterator
parameter. The shard
iterator specifies the position in the shard from which you want to
start reading stream records sequentially. If there are no stream
records available in the portion of the shard that the iterator points
to, get_records
returns an empty list.
Note that it might take multiple calls to get to a portion of the shard
that contains stream records.
get_records
can retrieve a maximum of 1
MB of data or 1000 stream records, whichever comes first.
dynamodbstreams_get_records(ShardIterator, Limit)
A list with the following syntax:
list(
Records = list(
list(
eventID = "string",
eventName = "INSERT"|"MODIFY"|"REMOVE",
eventVersion = "string",
eventSource = "string",
awsRegion = "string",
dynamodb = list(
ApproximateCreationDateTime = as.POSIXct(
"2015-01-01"
),
Keys = list(
list(
S = "string",
N = "string",
B = raw,
SS = list(
"string"
),
NS = list(
"string"
),
BS = list(
raw
),
M = list(
list()
),
L = list(
list()
),
NULL = TRUE|FALSE,
BOOL = TRUE|FALSE
)
),
NewImage = list(
list(
S = "string",
N = "string",
B = raw,
SS = list(
"string"
),
NS = list(
"string"
),
BS = list(
raw
),
M = list(
list()
),
L = list(
list()
),
NULL = TRUE|FALSE,
BOOL = TRUE|FALSE
)
),
OldImage = list(
list(
S = "string",
N = "string",
B = raw,
SS = list(
"string"
),
NS = list(
"string"
),
BS = list(
raw
),
M = list(
list()
),
L = list(
list()
),
NULL = TRUE|FALSE,
BOOL = TRUE|FALSE
)
),
SequenceNumber = "string",
SizeBytes = 123,
StreamViewType = "NEW_IMAGE"|"OLD_IMAGE"|"NEW_AND_OLD_IMAGES"|"KEYS_ONLY"
),
userIdentity = list(
PrincipalId = "string",
Type = "string"
)
)
),
NextShardIterator = "string"
)
[required] A shard iterator that was retrieved from a previous GetShardIterator operation. This iterator can be used to access the stream records in this shard.
The maximum number of records to return from the shard. The upper limit is 1000.
svc$get_records(
ShardIterator = "string",
Limit = 123
)
if (FALSE) {
# The following example retrieves all the stream records from a shard.
svc$get_records(
ShardIterator = "arn:aws:dynamodb:us-west-2:111122223333:table/Forum/stre..."
)
}
Run the code above in your browser using DataLab