From 9e1284687a1100ab4427c1d257ba46f93a399d16 Mon Sep 17 00:00:00 2001 From: Almudena Sanz Date: Thu, 15 May 2025 11:54:05 -0700 Subject: [PATCH] replace SpanAttributes by semconv attributes (#3503) Co-authored-by: Riccardo Magliocchetti --- .../instrumentation/elasticsearch/__init__.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py b/instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py index 3dc32216d..3ca304b87 100644 --- a/instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py +++ b/instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py @@ -106,7 +106,10 @@ from opentelemetry.instrumentation.elasticsearch.package import _instruments from opentelemetry.instrumentation.elasticsearch.version import __version__ from opentelemetry.instrumentation.instrumentor import BaseInstrumentor from opentelemetry.instrumentation.utils import unwrap -from opentelemetry.semconv.trace import SpanAttributes +from opentelemetry.semconv._incubating.attributes.db_attributes import ( + DB_STATEMENT, + DB_SYSTEM, +) from opentelemetry.trace import SpanKind, Status, StatusCode, get_tracer from .utils import sanitize_body @@ -288,7 +291,7 @@ def _wrap_perform_request( if span.is_recording(): attributes = { - SpanAttributes.DB_SYSTEM: "elasticsearch", + DB_SYSTEM: "elasticsearch", } if url: attributes["elasticsearch.url"] = url @@ -297,9 +300,7 @@ def _wrap_perform_request( if body: # Don't set db.statement for bulk requests, as it can be very large if isinstance(body, dict): - attributes[SpanAttributes.DB_STATEMENT] = ( - sanitize_body(body) - ) + attributes[DB_STATEMENT] = sanitize_body(body) if params: attributes["elasticsearch.params"] = str(params) if doc_id: