Examples:
Example: To retrieve all the stream records from a shard
resp = client.get_records({
shard_iterator: "arn:aws:dynamodb:us-west-2:111122223333:table/Forum/stream/2015-05-20T20:51:10.252|1|AAAAAAAAAAEvJp6D+zaQ... <remaining characters omitted> ...",
})
{
next_shard_iterator: "arn:aws:dynamodb:us-west-2:111122223333:table/Forum/stream/2015-05-20T20:51:10.252|1|AAAAAAAAAAGQBYshYDEe ... <remaining characters omitted> ...",
records: [
{
aws_region: "us-west-2",
dynamodb: {
approximate_creation_date_time: Time.parse("1.46480646E9"),
keys: {
"ForumName" => {
s: "DynamoDB",
},
"Subject" => {
s: "DynamoDB Thread 3",
},
},
sequence_number: "300000000000000499659",
size_bytes: 41,
stream_view_type: "KEYS_ONLY",
},
event_id: "e2fd9c34eff2d779b297b26f5fef4206",
event_name: "INSERT",
event_source: "aws:dynamodb",
event_version: "1.0",
},
{
aws_region: "us-west-2",
dynamodb: {
approximate_creation_date_time: Time.parse("1.46480527E9"),
keys: {
"ForumName" => {
s: "DynamoDB",
},
"Subject" => {
s: "DynamoDB Thread 1",
},
},
sequence_number: "400000000000000499660",
size_bytes: 41,
stream_view_type: "KEYS_ONLY",
},
event_id: "4b25bd0da9a181a155114127e4837252",
event_name: "MODIFY",
event_source: "aws:dynamodb",
event_version: "1.0",
},
{
aws_region: "us-west-2",
dynamodb: {
approximate_creation_date_time: Time.parse("1.46480646E9"),
keys: {
"ForumName" => {
s: "DynamoDB",
},
"Subject" => {
s: "DynamoDB Thread 2",
},
},
sequence_number: "500000000000000499661",
size_bytes: 41,
stream_view_type: "KEYS_ONLY",
},
event_id: "740280c73a3df7842edab3548a1b08ad",
event_name: "REMOVE",
event_source: "aws:dynamodb",
event_version: "1.0",
},
],
}
Request syntax with placeholder values
resp = client.get_records({
shard_iterator: "ShardIterator", limit: 1,
})
Response structure
resp.records resp.records[0].event_id resp.records[0].event_name resp.records[0].event_version resp.records[0].event_source resp.records[0].aws_region resp.records[0].dynamodb.approximate_creation_date_time resp.records[0].dynamodb.keys resp.records[0].dynamodb.keys["AttributeName"] resp.records[0].dynamodb.new_image resp.records[0].dynamodb.new_image["AttributeName"] resp.records[0].dynamodb.old_image resp.records[0].dynamodb.old_image["AttributeName"] resp.records[0].dynamodb.sequence_number resp.records[0].dynamodb.size_bytes resp.records[0].dynamodb.stream_view_type resp.records[0].user_identity.principal_id resp.records[0].user_identity.type resp.next_shard_iterator
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4