tracing-cloudwatch 0.4.1

tracing-subscriber layer that sends your application's tracing events(logs) to AWS CloudWatch Logs
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

#[cfg(feature = "awssdk")]
#[tokio::main]
async fn main() {
    use aws_config::BehaviorVersion;
    use std::time::Duration;
    use tracing_subscriber::{filter, fmt, layer::SubscriberExt, util::SubscriberInitExt};
    let config = aws_config::load_defaults(BehaviorVersion::latest()).await;
    let cw_client = aws_sdk_cloudwatchlogs::Client::new(&config);

    let (cw_layer, cw_guard) = tracing_cloudwatch::layer()
        .with_code_location(true)
        .with_target(false)
        .with_client(
            cw_client,
            tracing_cloudwatch::ExportConfig::default()
                .with_batch_size(1)
                .with_interval(Duration::from_secs(1))
                .with_log_group_name("tracing-cloudwatch")
                .with_log_stream_name("stream-1"),
        );

    tracing_subscriber::registry::Registry::default()
        .with(fmt::layer().with_ansi(true))
        .with(filter::LevelFilter::INFO)
        .with(cw_layer)
        .init();

    start().await;

    tokio::time::sleep(Duration::from_secs(10)).await;
    cw_guard.shutdown().await;
}

#[cfg(not(feature = "awssdk"))]
fn main() {}

#[cfg(feature = "awssdk")]
#[tracing::instrument()]
async fn start() {
    tracing::info!("Starting...");
}