opentelemetry_elasticsearch_instrumentation_console_trace_export.py

1from elasticsearch import Elasticsearch
2from opentelemetry import trace
3from opentelemetry.instrumentation.elasticsearch import ElasticsearchInstrumentor
4from opentelemetry.sdk.trace import TracerProvider
5from opentelemetry.sdk.trace.export import (
6    ConsoleSpanExporter,
7    SimpleSpanProcessor,
8)
9
10# Set up tracing
11trace.set_tracer_provider(TracerProvider())
12trace.get_tracer_provider().add_span_processor(
13    SimpleSpanProcessor(ConsoleSpanExporter())
14)
15
16# Instrument Elasticsearch
17ElasticsearchInstrumentor().instrument()
18
19# Use the Elasticsearch client as usual
20es = Elasticsearch([{"host": "localhost", "port": 9200}])
21es.indices.create(index="test-index", ignore=400)
22es.index(index="test-index", id=42, body={"any": "data", "timestamp": "now"})
23res = es.get(index="test-index", id=42)
24print(res)