Merge branch 'main' into botocore-span-attributes-removal

Author: xrmx

CHANGELOG.md

@@ -27,6 +27,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#3938](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3938))
 - `opentelemetry-instrumentation-aiohttp-server`: Support passing `TracerProvider` when instrumenting.
   ([#3819](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3819))
+- `opentelemetry-instrumentation-system-metrics`: Add support for the `OTEL_PYTHON_SYSTEM_METRICS_EXCLUDED_METRICS` environment variable
+  ([#3959](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3959))
 - `opentelemetry-instrumentation-httpx`: add ability to capture custom headers 
   ([#4047](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4047))
 
@@ -46,6 +48,18 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#4059](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4059))
 - `opentelemetry-instrumentation-botocore`: Replace SpanAttributes with semconv constants where applicable 
   ([#4063](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4063))
+- `opentelemetry-instrumentation-celery`: Replace SpanAttributes with semconv constants where applicable
+  ([#4056](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4056))
+- `opentelemetry-instrumentation-confluent-kafka`: Replace SpanAttributes with semconv constants where applicable
+  ([#4057](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4057))
+- `opentelemetry-instrumentation-cassandra`: Replace SpanAttributes with semconv constants for DB attributes
+  ([#4055](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4055))
+- `opentelemetry-instrumentation-falcon`: Replace SpanAttributes with semconv constants
+  ([#4066](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4066))
+- `opentelemetry-instrumentation-pika`: Replace SpanAttributes with semconv constants for net attributes
+  ([#4068](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4068))
+- `opentelemetry-instrumentation-mysqlclient`: Replace SpanAttributes with semconv constants
+  ([#4067](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4067))
 
 ## Version 1.39.0/0.60b0 (2025-12-03)
 

CONTRIBUTING.md

@@ -8,7 +8,7 @@ See the [public meeting notes](https://docs.google.com/document/d/18w8zOBm_mbety
 for a summary description of past meetings. To request edit access, join the
 meeting or get in touch on [Slack](https://cloud-native.slack.com/archives/C01PD4HUVBL).
 
-See to the [community membership document](https://github.com/open-telemetry/community/blob/main/community-membership.md)
+See the [community membership document](https://github.com/open-telemetry/community/blob/main/community-membership.md)
 on how to become a [**Member**](https://github.com/open-telemetry/community/blob/main/community-membership.md#member),
 [**Approver**](https://github.com/open-telemetry/community/blob/main/community-membership.md#approver)
 and [**Maintainer**](https://github.com/open-telemetry/community/blob/main/community-membership.md#maintainer).

docs/instrumentation/system_metrics/system_metrics.rst

@@ -5,3 +5,8 @@ OpenTelemetry system metrics Instrumentation
     :members:
     :undoc-members:
     :show-inheritance:
+
+.. automodule:: opentelemetry.instrumentation.system_metrics.environment_variables
+    :members:
+    :undoc-members:
+    :show-inheritance:

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

@@ -47,7 +47,14 @@
 from opentelemetry.instrumentation.cassandra.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_NAME,
+    DB_STATEMENT,
+    DB_SYSTEM,
+)
+from opentelemetry.semconv._incubating.attributes.net_attributes import (
+    NET_PEER_NAME,
+)
 
 
 def _instrument(tracer_provider, include_db_statement=False):
@@ -68,16 +75,16 @@ def _traced_execute_async(func, instance, args, kwargs):
             name, kind=trace.SpanKind.CLIENT
         ) as span:
             if span.is_recording():
-                span.set_attribute(SpanAttributes.DB_NAME, instance.keyspace)
-                span.set_attribute(SpanAttributes.DB_SYSTEM, "cassandra")
+                span.set_attribute(DB_NAME, instance.keyspace)
+                span.set_attribute(DB_SYSTEM, "cassandra")
                 span.set_attribute(
-                    SpanAttributes.NET_PEER_NAME,
+                    NET_PEER_NAME,
                     instance.cluster.contact_points,
                 )
 
                 if include_db_statement:
                     query = args[0]
-                    span.set_attribute(SpanAttributes.DB_STATEMENT, str(query))
+                    span.set_attribute(DB_STATEMENT, str(query))
 
             response = func(*args, **kwargs)
             return response

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

@@ -76,7 +76,9 @@ def add(x, y):
 from opentelemetry.metrics import get_meter
 from opentelemetry.propagate import extract, inject
 from opentelemetry.propagators.textmap import Getter
-from opentelemetry.semconv.trace import SpanAttributes
+from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
+    MESSAGING_MESSAGE_ID,
+)
 from opentelemetry.trace.status import Status, StatusCode
 
 if VERSION >= (4, 0, 1):
@@ -240,7 +242,7 @@ def _trace_before_publish(self, *args, **kwargs):
         # apply some attributes here because most of the data is not available
         if span.is_recording():
             span.set_attribute(_TASK_TAG_KEY, _TASK_APPLY_ASYNC)
-            span.set_attribute(SpanAttributes.MESSAGING_MESSAGE_ID, task_id)
+            span.set_attribute(MESSAGING_MESSAGE_ID, task_id)
             span.set_attribute(_TASK_NAME_KEY, task_name)
             utils.set_attributes_from_context(span, kwargs)
 

instrumentation/opentelemetry-instrumentation-celery/src/opentelemetry/instrumentation/celery/utils.py

@@ -20,6 +20,9 @@
 from celery import registry  # pylint: disable=no-name-in-module
 from celery.app.task import Task
 
+from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
+    MESSAGING_MESSAGE_ID,
+)
 from opentelemetry.semconv.trace import SpanAttributes
 from opentelemetry.trace import Span
 
@@ -98,7 +101,7 @@ def set_attributes_from_context(span, context):
             value = str(value)
 
         elif key == "id":
-            attribute_name = SpanAttributes.MESSAGING_MESSAGE_ID
+            attribute_name = MESSAGING_MESSAGE_ID
 
         elif key == "correlation_id":
             attribute_name = SpanAttributes.MESSAGING_CONVERSATION_ID

instrumentation/opentelemetry-instrumentation-celery/tests/test_tasks.py

@@ -20,11 +20,22 @@
 from opentelemetry import baggage, context
 from opentelemetry.instrumentation.celery import CeleryInstrumentor, utils
 from opentelemetry.instrumentation.utils import unwrap
+from opentelemetry.semconv.attributes.exception_attributes import (
+    EXCEPTION_MESSAGE,
+    EXCEPTION_STACKTRACE,
+    EXCEPTION_TYPE,
+)
 from opentelemetry.semconv.trace import SpanAttributes
 from opentelemetry.test.test_base import TestBase
 from opentelemetry.trace import SpanKind, StatusCode
 
-from .celery_test_tasks import app, task_add, task_raises, task_returns_baggage
+from .celery_test_tasks import (
+    CustomError,
+    app,
+    task_add,
+    task_raises,
+    task_returns_baggage,
+)
 
 
 class TestCeleryInstrumentation(TestBase):
@@ -127,15 +138,15 @@ def test_task_raises(self):
         self.assertEqual(1, len(consumer.events))
         event = consumer.events[0]
 
-        self.assertIn(SpanAttributes.EXCEPTION_STACKTRACE, event.attributes)
+        self.assertIn(EXCEPTION_STACKTRACE, event.attributes)
 
-        # TODO: use plain assertEqual after 1.25 is released (https://github.com/open-telemetry/opentelemetry-python/pull/3837)
-        self.assertIn(
-            "CustomError", event.attributes[SpanAttributes.EXCEPTION_TYPE]
+        self.assertEqual(
+            f"{CustomError.__module__}.{CustomError.__qualname__}",
+            event.attributes[EXCEPTION_TYPE],
         )
 
         self.assertEqual(
-            event.attributes[SpanAttributes.EXCEPTION_MESSAGE],
+            event.attributes[EXCEPTION_MESSAGE],
             "The task failed!",
         )
 

instrumentation/opentelemetry-instrumentation-celery/tests/test_utils.py

@@ -20,6 +20,9 @@
 from opentelemetry import trace as trace_api
 from opentelemetry.instrumentation.celery import utils
 from opentelemetry.sdk import trace
+from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
+    MESSAGING_MESSAGE_ID,
+)
 from opentelemetry.semconv.trace import SpanAttributes
 
 
@@ -47,7 +50,7 @@ def test_set_attributes_from_context(self):
         utils.set_attributes_from_context(span, context)
 
         self.assertEqual(
-            span.attributes.get(SpanAttributes.MESSAGING_MESSAGE_ID),
+            span.attributes.get(MESSAGING_MESSAGE_ID),
             "44b7f305",
         )
         self.assertEqual(

instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py

@@ -110,7 +110,9 @@ def instrument_consumer(consumer: Consumer, tracer_provider=None)
 from opentelemetry import context, propagate, trace
 from opentelemetry.instrumentation.instrumentor import BaseInstrumentor
 from opentelemetry.instrumentation.utils import unwrap
-from opentelemetry.semconv.trace import MessagingOperationValues
+from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
+    MessagingOperationTypeValues,
+)
 from opentelemetry.trace import Tracer
 
 from .package import _instruments
@@ -363,7 +365,7 @@ def wrap_produce(func, instance, tracer, args, kwargs):
             _enrich_span(
                 span,
                 topic,
-                operation=MessagingOperationValues.RECEIVE,
+                operation=MessagingOperationTypeValues.RECEIVE,
             )  # Replace
             propagate.inject(
                 headers,
@@ -387,7 +389,7 @@ def wrap_poll(func, instance, tracer, args, kwargs):
                     record.topic(),
                     record.partition(),
                     record.offset(),
-                    operation=MessagingOperationValues.PROCESS,
+                    operation=MessagingOperationTypeValues.PROCESS,
                 )
         instance._current_context_token = context.attach(
             trace.set_span_in_context(instance._current_consume_span)
@@ -409,7 +411,7 @@ def wrap_consume(func, instance, tracer, args, kwargs):
                 _enrich_span(
                     instance._current_consume_span,
                     records[0].topic(),
-                    operation=MessagingOperationValues.PROCESS,
+                    operation=MessagingOperationTypeValues.PROCESS,
                 )
 
         instance._current_context_token = context.attach(

instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/utils.py

@@ -3,9 +3,14 @@
 
 from opentelemetry import context, propagate
 from opentelemetry.propagators import textmap
+from opentelemetry.semconv._incubating.attributes.messaging_attributes import (
+    MESSAGING_MESSAGE_ID,
+    MESSAGING_OPERATION,
+    MESSAGING_SYSTEM,
+    MessagingOperationTypeValues,
+)
 from opentelemetry.semconv.trace import (
     MessagingDestinationKindValues,
-    MessagingOperationValues,
     SpanAttributes,
 )
 from opentelemetry.trace import Link, SpanKind
@@ -115,12 +120,12 @@ def _enrich_span(
     topic,
     partition: Optional[int] = None,
     offset: Optional[int] = None,
-    operation: Optional[MessagingOperationValues] = None,
+    operation: Optional[MessagingOperationTypeValues] = None,
 ):
     if not span.is_recording():
         return
 
-    span.set_attribute(SpanAttributes.MESSAGING_SYSTEM, "kafka")
+    span.set_attribute(MESSAGING_SYSTEM, "kafka")
     span.set_attribute(SpanAttributes.MESSAGING_DESTINATION, topic)
 
     if partition is not None:
@@ -132,15 +137,15 @@ def _enrich_span(
     )
 
     if operation:
-        span.set_attribute(SpanAttributes.MESSAGING_OPERATION, operation.value)
+        span.set_attribute(MESSAGING_OPERATION, operation.value)
     else:
         span.set_attribute(SpanAttributes.MESSAGING_TEMP_DESTINATION, True)
 
     # https://stackoverflow.com/questions/65935155/identify-and-find-specific-message-in-kafka-topic
     # A message within Kafka is uniquely defined by its topic name, topic partition and offset.
     if partition is not None and offset is not None and topic:
         span.set_attribute(
-            SpanAttributes.MESSAGING_MESSAGE_ID,
+            MESSAGING_MESSAGE_ID,
             f"{topic}.{partition}.{offset}",
         )