Get Records

dynamodbstreams_get_records

R Documentation

Retrieves the stream records from a given shard

Description

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.

Usage

dynamodbstreams_get_records(ShardIterator, Limit)

Arguments

ShardIterator

[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.

Limit

The maximum number of records to return from the shard. The upper limit is 1000.

Value

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"
)

Request syntax

svc$get_records(
  ShardIterator = "string",
  Limit = 123
)

Examples

## Not run: 
# 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..."
)

## End(Not run)