Support for Custom Runtime about aws-otel-lambda HOT 3 CLOSED

fn init_tracer() -> sdkTracer {
    global::set_text_map_propagator(XrayPropagator::

    // Install stdout exporter pipeline to be able to retrieve the e collected spans.
    // For the demonstration, use `Sampler::AlwaysOn` sampler to sample all traces. In a production
    // application, use `Sampler::ParentBased` or `Sampler::TraceIdRatioBased` with a desired ratio.
    stdout::new_pipeline()
        .with_trace_config(
            config()
                .with_sampler(Sampler::AlwaysOn)
                .with_id_generator(XrayIdGenerator::default()),
        )
        .install_simple()
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    let tracer = init_tracer();
    
    tracing_subscriber::fmt()
        .with_ansi(false)
        .without_time()
        .with_max_level(tracing_subscriber::filter::LevelFilter::INFO)
        .init();

    let config = aws_config::load_from_env().await;
    let dynamodb_client = aws_sdk_dynamodb::Client::new(&config);

    // other stuff

    lambda_http::run(service_fn(|event: Request| {
      tracer.in_span("root", |cx| {
           my_handler(event, cx)
      })
    })).await?;
   
    global::shutdown_tracer_provider();
    Ok(())
}

pub async fn my_handler(event: Request, ctx: Context) -> Result<impl IntoResponse, Error> {
   ctx.span().add_event("calling dyanmodb", vec![]);
  //dynamodb query
  ctx.spaIt).add_event("doing something else", vec![]);
}