-
Notifications
You must be signed in to change notification settings - Fork 1
/
local-chaine.rs
41 lines (35 loc) · 1.64 KB
/
local-chaine.rs
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
use env_applier::EnvApply;
use std::env;
use std::io;
use tracing_subscriber::prelude::__tracing_subscriber_SubscriberExt;
use tracing_subscriber::util::SubscriberInitExt;
use tracing_subscriber::EnvFilter;
use tracing_subscriber::{self, Layer};
#[async_std::main]
async fn main() -> io::Result<()> {
let mut layers = Vec::new();
let (non_blocking, _guard) = tracing_appender::non_blocking(io::stdout());
let layer = tracing_subscriber::fmt::layer()
.pretty()
.with_line_number(true)
.with_writer(non_blocking)
.with_filter(EnvFilter::from_default_env())
.boxed();
layers.push(layer);
tracing_subscriber::registry().with(layers).init();
let config = r#"
[
{"type":"e","connector":{"type":"local","path":"./data/out/cascade_file*"}}
,{"type":"r","connector":{"type":"local","path":"./data/multi_lines.{{ metadata.mime_subtype }}"}}
,{"type":"t","actions":[{"field":"/","pattern":"{% if input.number == 10 %}{{ throw(message='data write in the file cascade_file2.json') }}{% else %}{{ input | json_encode() }}{% endif %}"}]}
,{"type":"w","connector":{"type":"local","path":"./data/out/cascade_file1.{{ metadata.mime_subtype }}"},"data_type":"ok"}
,{"type":"w","connector":{"type":"local","path":"./data/out/cascade_file2.{{ metadata.mime_subtype }}"},"data_type":"err"}
]
"#;
let config_resolved = env::Vars::apply(config.to_string());
chewdata::exec(serde_json::from_str(config_resolved.as_str())?, None, None).await?;
tracing::info!(
"Check the files `./data/out/cascade_file1.json` and `./data/out/cascade_file2.json`"
);
Ok(())
}