dataflow-rs 3.0.1

A lightweight rules engine for building IFTTT-style automation and data processing pipelines in Rust. Define rules with JSONLogic conditions, execute actions, and chain workflows.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! # Hello World
//!
//! The smallest possible dataflow-rs program. `parse_json` copies the
//! payload into `data.input`, then `map` builds a greeting from it.
//! Run with: `cargo run --example hello_world`

use dataflow_rs::prelude::*;
use serde_json::json;

#[tokio::main]
async fn main() -> Result<()> {
    let workflow = Workflow::from_json(
        r#"{
            "id": "hello",
            "name": "Hello World",
            "tasks": [
                {
                    "id": "load",
                    "name": "Load payload into data.input",
                    "function": {
                        "name": "parse_json",
                        "input": { "source": "payload", "target": "input" }
                    }
                },
                {
                    "id": "greet",
                    "name": "Build greeting",
                    "function": {
                        "name": "map",
                        "input": {
                            "mappings": [
                                {
                                    "path": "data.greeting",
                                    "logic": { "cat": ["Hello, ", {"var": "data.input.name"}, "!"] }
                                }
                            ]
                        }
                    }
                }
            ]
        }"#,
    )?;

    let engine = Engine::builder().with_workflow(workflow).build()?;
    let mut message = Message::from_value(&json!({"name": "World"}));
    engine.process_message(&mut message).await?;

    println!("{}", message.data()["greeting"]);
    Ok(())
}