aleeve.dev / ott
Scalable and distributed custom feed generator, ott - on that topic
fork atom
ott / smart-modules / assign-record-key /
at main 1 folder 7 files
src
.gitignore
Cargo.lock
Cargo.toml
README.md
SmartModule.toml
rust-toolchain.toml
test_transformation.yaml
README.md

Fluvio SmartModules#

Note: To compile a SmartModule, you will need to install the wasm32-wasip1 target by running rustup target add wasm32-wasip1, or rustup target add wasm32-unknown-unknown if using the --nowasi flags

About SmartModules#

Fluvio SmartModules are custom plugins that can be used to manipulate streaming data in a topic. SmartModules are written in Rust and compiled to WebAssembly. To use a SmartModule, you simply provide the .wasm file to the Fluvio consumer, which uploads it to the Streaming Processing Unit (SPU) where it runs your SmartModule code on each record before sending it to the consumer.

Using SmartModules with the Fluvio CLI#

Make sure to follow the Fluvio getting started guide, then create a new topic to send data to.

fluvio topic create smartmodule-test
cargo build --release
fluvio consume smartmodule-test -B --map="target/wasm32-wasip1/release-lto/assign-record-key"