Dynamodb::Streams::Client
DynamoDB Streams client.
Installation
Add this line to your application's Gemfile:
gem 'dynamodb-streams-client'And then execute:
$ bundle
Or install it yourself as:
$ gem install dynamodb-streams-client
Usage
require 'dynamodb/streams/client'
require 'pp'
client = DynamoDB::Streams::Client.new(
access_key_id: 'YOUR_ACCESS_KEY_ID',
secret_access_key: 'YOUR_SECRET_ACCESS_KEY',
endpoint: '...')
#client.debug = true
pp client.query('ListStreams')
#=> {"StreamIds"=>
# ["...",
# "...",
# "..."]}CLI
$ dynamodb-streams
Commands:
dynamodb-streams describe_stream STREAM_ID # Returns information about a stream
dynamodb-streams get_records SHARD_ITERATOR # Retrieves the stream records
dynamodb-streams get_shard_iterator STREAM_ID SHARD_ID SHARD_ITERATOR_TYPE # Returns a shard iterator
dynamodb-streams help [COMMAND] # Describe available commands or one specific command
dynamodb-streams list_streams # Returns an array of stream IDs
Options:
-k, [--access-key=ACCESS-KEY]
-s, [--secret-key=SECRET-KEY]
-e, [--endpoint=ENDPOINT]
-r, [--region=REGION]
[--debug=DEBUG]
$ export AWS_ACCESS_KEY_ID=...
$ export AWS_SECRET_ACCESS_KEY=...
$ export DYNAMODB_STREAMS_ENDPOINT=...
$ dynamodb-streams list_streams
{
"StreamIds": [
"...",Follow record
dynamodb-streams get_records xxxxxxxx-xxxx-... -f --limit 10