Skip to content

Commit 891864b

Browse files
committed
Enable gzip compression and 30s timeout for OTLP exporters
Reduces bandwidth usage and avoids hangs on slow networks for trace, metric, and log exports.
1 parent c8c5d3a commit 891864b

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

plain-cloud/plain/cloud/config.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55

66
from opentelemetry import _logs, metrics, trace
77
from opentelemetry._logs._internal import ProxyLoggerProvider
8+
from opentelemetry.exporter.otlp.proto.http import Compression
89
from opentelemetry.exporter.otlp.proto.http._log_exporter import OTLPLogExporter
910
from opentelemetry.exporter.otlp.proto.http.metric_exporter import OTLPMetricExporter
1011
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
@@ -84,6 +85,8 @@ def ready(self) -> None:
8485
span_exporter = OTLPSpanExporter(
8586
endpoint=f"{export_url}/v1/traces",
8687
headers=headers,
88+
timeout=30,
89+
compression=Compression.Gzip,
8790
)
8891
sampler = sampling.TraceIdRatioBased(settings.CLOUD_TRACE_SAMPLE_RATE)
8992
tracer_provider = TracerProvider(sampler=sampler, resource=resource)
@@ -96,6 +99,8 @@ def ready(self) -> None:
9699
metric_exporter = OTLPMetricExporter(
97100
endpoint=f"{export_url}/v1/metrics",
98101
headers=headers,
102+
timeout=30,
103+
compression=Compression.Gzip,
99104
preferred_temporality={
100105
Counter: AggregationTemporality.DELTA,
101106
Histogram: AggregationTemporality.DELTA,
@@ -131,6 +136,8 @@ def ready(self) -> None:
131136
log_exporter = OTLPLogExporter(
132137
endpoint=f"{export_url}/v1/logs",
133138
headers=headers,
139+
timeout=30,
140+
compression=Compression.Gzip,
134141
)
135142
logger_provider = LoggerProvider(resource=resource)
136143
logger_provider.add_log_record_processor(

0 commit comments

Comments
 (0)