Replaced usage of opentelemetry.semconv.trace with opentelemetry.semconv._incubating.attributes.

Author: hegerchr

instrumentation/opentelemetry-instrumentation-redis/src/opentelemetry/instrumentation/redis/__init__.py

@@ -135,7 +135,7 @@ def response_hook(span, instance, response):
 )
 from opentelemetry.instrumentation.redis.version import __version__
 from opentelemetry.instrumentation.utils import unwrap
-from opentelemetry.semconv.trace import SpanAttributes
+from opentelemetry.semconv._incubating.attributes.db_attributes import DB_STATEMENT
 from opentelemetry.trace import (
     StatusCode,
     Tracer,
@@ -200,7 +200,7 @@ def _traced_execute_command(
             name, kind=trace.SpanKind.CLIENT
         ) as span:
             if span.is_recording():
-                span.set_attribute(SpanAttributes.DB_STATEMENT, query)
+                span.set_attribute(DB_STATEMENT, query)
                 _set_connection_attributes(span, instance)
                 span.set_attribute("db.redis.args_length", len(args))
                 if span.name == "redis.create_index":
@@ -239,7 +239,7 @@ def _traced_execute_pipeline(
             span_name, kind=trace.SpanKind.CLIENT
         ) as span:
             if span.is_recording():
-                span.set_attribute(SpanAttributes.DB_STATEMENT, resource)
+                span.set_attribute(DB_STATEMENT, resource)
                 _set_connection_attributes(span, instance)
                 span.set_attribute(
                     "db.redis.pipeline_length", len(command_stack)
@@ -281,7 +281,7 @@ async def _async_traced_execute_command(
             name, kind=trace.SpanKind.CLIENT
         ) as span:
             if span.is_recording():
-                span.set_attribute(SpanAttributes.DB_STATEMENT, query)
+                span.set_attribute(DB_STATEMENT, query)
                 _set_connection_attributes(span, instance)
                 span.set_attribute("db.redis.args_length", len(args))
             if callable(request_hook):
@@ -317,7 +317,7 @@ async def _async_traced_execute_pipeline(
             span_name, kind=trace.SpanKind.CLIENT
         ) as span:
             if span.is_recording():
-                span.set_attribute(SpanAttributes.DB_STATEMENT, resource)
+                span.set_attribute(DB_STATEMENT, resource)
                 _set_connection_attributes(span, instance)
                 span.set_attribute(
                     "db.redis.pipeline_length", len(command_stack)

instrumentation/opentelemetry-instrumentation-redis/tests/test_redis.py

@@ -25,11 +25,18 @@
 
 from opentelemetry import trace
 from opentelemetry.instrumentation.redis import RedisInstrumentor
-from opentelemetry.semconv.trace import (
+from opentelemetry.semconv._incubating.attributes.db_attributes import (
+    DB_SYSTEM,
+    DB_REDIS_DATABASE_INDEX,
     DbSystemValues,
+)
+from opentelemetry.semconv._incubating.attributes.net_attributes import (
+    NET_PEER_NAME,
+    NET_PEER_PORT,
+    NET_TRANSPORT,
     NetTransportValues,
-    SpanAttributes,
 )
+
 from opentelemetry.test.test_base import TestBase
 from opentelemetry.trace import SpanKind
 
@@ -257,18 +264,18 @@ def test_attributes_default(self):
 
         span = spans[0]
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_SYSTEM],
+            span.attributes[DB_SYSTEM],
             DbSystemValues.REDIS.value,
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_REDIS_DATABASE_INDEX], 0
+            span.attributes[DB_REDIS_DATABASE_INDEX], 0
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_PEER_NAME], "localhost"
+            span.attributes[NET_PEER_NAME], "localhost"
         )
-        self.assertEqual(span.attributes[SpanAttributes.NET_PEER_PORT], 6379)
+        self.assertEqual(span.attributes[NET_PEER_PORT], 6379)
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_TRANSPORT],
+            span.attributes[NET_TRANSPORT],
             NetTransportValues.IP_TCP.value,
         )
 
@@ -283,18 +290,18 @@ def test_attributes_tcp(self):
 
         span = spans[0]
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_SYSTEM],
+            span.attributes[DB_SYSTEM],
             DbSystemValues.REDIS.value,
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_REDIS_DATABASE_INDEX], 1
+            span.attributes[DB_REDIS_DATABASE_INDEX], 1
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_PEER_NAME], "1.1.1.1"
+            span.attributes[NET_PEER_NAME], "1.1.1.1"
         )
-        self.assertEqual(span.attributes[SpanAttributes.NET_PEER_PORT], 6380)
+        self.assertEqual(span.attributes[NET_PEER_PORT], 6380)
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_TRANSPORT],
+            span.attributes[NET_TRANSPORT],
             NetTransportValues.IP_TCP.value,
         )
 
@@ -311,18 +318,18 @@ def test_attributes_unix_socket(self):
 
         span = spans[0]
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_SYSTEM],
+            span.attributes[DB_SYSTEM],
             DbSystemValues.REDIS.value,
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.DB_REDIS_DATABASE_INDEX], 3
+            span.attributes[DB_REDIS_DATABASE_INDEX], 3
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_PEER_NAME],
+            span.attributes[NET_PEER_NAME],
             "/path/to/socket.sock",
         )
         self.assertEqual(
-            span.attributes[SpanAttributes.NET_TRANSPORT],
+            span.attributes[NET_TRANSPORT],
             NetTransportValues.OTHER.value,
         )