Crate dynamo_subscriber

Wrap Amazon DynamoDB Streams and use it as Rust Stream.

Getting Started

A simple example is as follows. Edit your Cargo.toml at first.

[dependencies]
dynamo-subscriber = "0.1"
aws-config = "1.0.1"
tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
tokio-stream = "0.1.14"

Then in code, assuming that the dynamodb-local instance is running on localhost:8000 and “People” table exists, you can subscribe dynamodb streams from “People” table with the following.

This stream emits a vector of Record.

use aws_config::BehaviorVersion;
use dynamo_subscriber as subscriber;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() {
    let config = aws_config::load_defaults(BehaviorVersion::latest())
        .await
        .into_builder()
        .endpoint_url("http://localhost:8000")
        .build();

    let client = subscriber::Client::new(&config);
    let mut stream = subscriber::stream::builder()
        .table_name("People")
        .client(client)
        .build();

    while let Some(records) = stream.next().await {
        println!("{:#?}", records);
    }
}

AWS SDK Dependency

To build Client of this crate, you must pass the reference for SdkConfig.

Re-exports

• pub use client::Client;
• pub use client::DynamodbClient;

Modules

• client
  Client for calling AWS APIs.
• error
  Common errors.
• stream
  Implementation for Dynamodb Streams.
• types
  Data structures used by operations.