Instrument Rust applications with OpenTelemetry

• Create the following functions to initialize the tracer:

rustcopydownload
use std::io::{BufRead, BufReader, Read};

use opentelemetry::{
    global,
    sdk::{propagation::TraceContextPropagator, trace as sdktrace, Resource},
    trace::{Span, TraceContextExt, TraceError, Tracer},
    Context, KeyValue,
};

use opentelemetry_http::{HeaderExtractor, HeaderInjector};
use opentelemetry_otlp::WithExportConfig;
use opentelemetry_semantic_conventions as semcov;

fn read_dt_metadata() -> Resource {
    fn read_single(path: &str, metadata: &mut Vec<KeyValue>) -> std::io::Result<()> {
        let mut file = std::fs::File::open(path)?;
        if path.starts_with("dt_metadata") {
            let mut name = String::new();
            file.read_to_string(&mut name)?;

            file = std::fs::File::open(name)?;
        }

        for line in BufReader::new(file).lines() {
            if let Some((k, v)) = line?.split_once('=') {
                metadata.push(KeyValue::new(k.to_string(), v.to_string()))
            }
        }

        Ok(())
    }

    let mut metadata = Vec::new();
    for name in [
        "dt_metadata_e617c525669e072eebe3d0f08212e8f2.properties",
        "/var/lib/dynatrace/enrichment/dt_metadata.properties",
    ] {
        let _ = read_single(name, &mut metadata);
    }

    Resource::new(metadata)
}

fn init_tracer() -> Result<sdktrace::Tracer, TraceError> {
    global::set_text_map_propagator(TraceContextPropagator::new());


    let mut resource = Resource::new(vec![
        semcov::resource::SERVICE_NAME.string("rust-quickstart"), //TODO Replace with the name of your application
        semcov::resource::SERVICE_VERSION.string("1.0.1"), //TODO Replace with the version of your application
    ]);

    resource = resource.merge(&read_dt_metadata());

    opentelemetry_otlp::new_pipeline()
        .tracing()
        .with_exporter(
            opentelemetry_otlp::new_exporter()
                .http()
                .with_endpoint("http://localhost:14499/otlp/v1/traces"),
        )
        .with_trace_config(
            sdktrace::config()
                .with_resource(resource)
                .with_sampler(sdktrace::Sampler::AlwaysOn),
        )
        .install_batch(opentelemetry::runtime::Tokio)
}

When using OneAgent, make sure to enable the public EEC (Extension Execution Controller) in your Dynatrace Settings, otherwise no data will be sent.

In the Dynatrace menu, navigate to Settings > Monitoring > Monitored technologies, scroll down and go to Dynatrace OneAgent StatsD, Pipe, HTTP Metric API.
The toggle Enable Extension Execution Controller on every host should be active.

• Create the following functions to initialize the tracer:

rustcopydownload
use std::collections::HashMap;
use std::io::{BufRead, BufReader, Read};

use opentelemetry::{
    global,
    sdk::{propagation::TraceContextPropagator, trace as sdktrace, Resource},
    trace::{Span, TraceContextExt, TraceError, Tracer},
    Context, KeyValue,
};

use opentelemetry_http::{HeaderExtractor, HeaderInjector};
use opentelemetry_otlp::WithExportConfig;
use opentelemetry_semantic_conventions as semcov;

fn read_dt_metadata() -> Resource {
    fn read_single(path: &str, metadata: &mut Vec<KeyValue>) -> std::io::Result<()> {
        let mut file = std::fs::File::open(path)?;
        if path.starts_with("dt_metadata") {
            let mut name = String::new();
            file.read_to_string(&mut name)?;

            file = std::fs::File::open(name)?;
        }

        for line in BufReader::new(file).lines() {
            if let Some((k, v)) = line?.split_once('=') {
                metadata.push(KeyValue::new(k.to_string(), v.to_string()))
            }
        }

        Ok(())
    }

    let mut metadata = Vec::new();
    for name in [
        "dt_metadata_e617c525669e072eebe3d0f08212e8f2.properties",
        "/var/lib/dynatrace/enrichment/dt_metadata.properties",
    ] {
        let _ = read_single(name, &mut metadata);
    }

    Resource::new(metadata)
}

fn init_tracer() -> Result<sdktrace::Tracer, TraceError> {
    global::set_text_map_propagator(TraceContextPropagator::new());

    let mut map = HashMap::new();
    map.insert("Authorization".to_string(), "Api-Token <TOKEN>".to_string()); //TODO Replace <TOKEN> with your API Token as mentioned in the next step

    let mut resource = Resource::new(vec![
        semcov::resource::SERVICE_NAME.string("rust-quickstart"), //TODO Replace with the name of your application
        semcov::resource::SERVICE_VERSION.string("1.0.1"), //TODO Replace with the version of your application
    ]);

    resource = resource.merge(&read_dt_metadata());

    opentelemetry_otlp::new_pipeline()
        .tracing()
        .with_exporter(
            opentelemetry_otlp::new_exporter()
                .http()
                .with_endpoint("<URL>") //TODO Replace <URL> to your SaaS/Managed-URL as mentioned in the next step
                .with_headers(map),
        )
        .with_trace_config(
            sdktrace::config()
                .with_resource(resource)
                .with_sampler(sdktrace::Sampler::AlwaysOn),
        )
        .install_batch(opentelemetry::runtime::Tokio)
}

Lastly, you need to define the correct endpoint and token, to make sure your data arrives where it should be.

• To set the endpoint:
  1. Use your Environment ID to set the endpoint to which your app will send traces as follows:
     • Dynatrace SaaS https://{your-environment-id}.live.dynatrace.com/api/v2/otlp/v1/traces
     • Dynatrace Managed https://{your-domain}/e/{your-environment-id}/api/v2/otlp/v1/traces
  2. Replace <URL> in the code snippet above with your endpoint.
• To create an authentication token
  1. In the Dynatrace menu, go to Access tokens and select Generate new token.
  2. Provide a Token name.
  3. In the Search scopes box, search for Ingest OpenTelemetry traces and select the checkbox.
  4. Select Generate token.
  5. Select Copy to copy the token to your clipboard.
  6. Save the token in a safe place; you can't display it again.
  7. Replace <TOKEN> in the code snippet above with your token.