|
10 | 10 | from locust import HttpUser, task, between
|
11 | 11 |
|
12 | 12 | from opentelemetry import context, baggage, trace
|
| 13 | +from opentelemetry.metrics import set_meter_provider |
| 14 | +from opentelemetry.sdk.metrics import MeterProvider |
| 15 | +from opentelemetry.sdk.metrics.export import MetricExporter, PeriodicExportingMetricReader |
13 | 16 | from opentelemetry.sdk.trace import TracerProvider
|
14 | 17 | from opentelemetry.sdk.trace.export import BatchSpanProcessor
|
15 |
| -from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter |
| 18 | +from opentelemetry.exporter.otlp.proto.grpc.metric_exporter import OTLPMetricExporter |
| 19 | +from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter |
| 20 | +from opentelemetry.instrumentation.jinja2 import Jinja2Instrumentor |
16 | 21 | from opentelemetry.instrumentation.requests import RequestsInstrumentor
|
| 22 | +from opentelemetry.instrumentation.system_metrics import SystemMetricsInstrumentor |
17 | 23 | from opentelemetry.instrumentation.urllib3 import URLLib3Instrumentor
|
18 | 24 |
|
| 25 | +exporter = OTLPMetricExporter(insecure=True) |
| 26 | +set_meter_provider(MeterProvider([PeriodicExportingMetricReader(exporter)])) |
| 27 | + |
19 | 28 | tracer_provider = TracerProvider()
|
20 | 29 | trace.set_tracer_provider(tracer_provider)
|
21 | 30 | tracer_provider.add_span_processor(BatchSpanProcessor(OTLPSpanExporter()))
|
22 | 31 |
|
23 | 32 | # Instrumenting manually to avoid error with locust gevent monkey
|
| 33 | +Jinja2Instrumentor().instrument() |
24 | 34 | RequestsInstrumentor().instrument()
|
| 35 | +SystemMetricsInstrumentor().instrument() |
25 | 36 | URLLib3Instrumentor().instrument()
|
26 | 37 |
|
27 | 38 | categories = [
|
|
0 commit comments