opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-08-02 19:47:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

replace SpanAttributes by semconv attributes (#3503)

Browse Source 
Co-authored-by: Riccardo Magliocchetti <riccardo.magliocchetti@gmail.com>
This commit is contained in:
Almudena Sanz
2025-05-15 11:54:05 -07:00
committed by GitHub
parent 1034b746af
commit 9e1284687a
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
instrumentation/opentelemetry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/__init__.py
View File

@ -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: