opentelemetry_threading_instrumentation_context_propagation_quickstart.py

1import threading
2from opentelemetry import trace
3from opentelemetry.instrumentation.threading import ThreadingInstrumentor
4
5# Initialize the instrumentation
6ThreadingInstrumentor().instrument()
7
8tracer = trace.get_tracer(__name__)
9
10def worker_thread():
11    # This span will automatically be a child of the span active 
12    # when the thread was started
13    with tracer.start_as_current_span("child_thread_span"):
14        print("Executing work in a thread...")
15
16with tracer.start_as_current_span("parent_span"):
17    t = threading.Thread(target=worker_thread)
18    t.start()
19    t.join()