sdk: Implement basic host resource detector

CHANGELOG.md

@@ -11,6 +11,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   ([#4154](https://github.com/open-telemetry/opentelemetry-python/pull/4154))
 - sdk: Add support for log formatting
   ([#4137](https://github.com/open-telemetry/opentelemetry-python/pull/4166))
+- sdk: Add Host resource detector
+  ([#4182](https://github.com/open-telemetry/opentelemetry-python/pull/4182))
 
 ## Version 1.27.0/0.48b0 (2024-08-28)
 

opentelemetry-sdk/src/opentelemetry/sdk/resources/__init__.py

@@ -60,6 +60,7 @@
 import logging
 import os
 import platform
+import socket
 import sys
 import typing
 from json import dumps
@@ -105,6 +106,7 @@
 FAAS_VERSION = ResourceAttributes.FAAS_VERSION
 FAAS_INSTANCE = ResourceAttributes.FAAS_INSTANCE
 HOST_NAME = ResourceAttributes.HOST_NAME
+HOST_ARCH = ResourceAttributes.HOST_ARCH
 HOST_TYPE = ResourceAttributes.HOST_TYPE
 HOST_IMAGE_NAME = ResourceAttributes.HOST_IMAGE_NAME
 HOST_IMAGE_ID = ResourceAttributes.HOST_IMAGE_ID
@@ -159,7 +161,7 @@ class Resource:
     _schema_url: str
 
     def __init__(
-        self, attributes: Attributes, schema_url: typing.Optional[str] = None
+            self, attributes: Attributes, schema_url: typing.Optional[str] = None
     ):
         self._attributes = BoundedAttributes(attributes=attributes)
         if schema_url is None:
@@ -168,8 +170,8 @@ def __init__(
 
     @staticmethod
     def create(
-        attributes: typing.Optional[Attributes] = None,
-        schema_url: typing.Optional[str] = None,
+            attributes: typing.Optional[Attributes] = None,
+            schema_url: typing.Optional[str] = None,
     ) -> "Resource":
         """Creates a new `Resource` from attributes.
 
@@ -188,8 +190,8 @@ def create(
             {
                 otel_experimental_resource_detector.strip()
                 for otel_experimental_resource_detector in environ.get(
-                    OTEL_EXPERIMENTAL_RESOURCE_DETECTORS, ""
-                ).split(",")
+                OTEL_EXPERIMENTAL_RESOURCE_DETECTORS, ""
+            ).split(",")
                 if otel_experimental_resource_detector
             }
         )
@@ -276,8 +278,8 @@ def __eq__(self, other: object) -> bool:
         if not isinstance(other, Resource):
             return False
         return (
-            self._attributes == other._attributes
-            and self._schema_url == other._schema_url
+                self._attributes == other._attributes
+                and self._schema_url == other._schema_url
         )
 
     def __hash__(self) -> int:
@@ -353,7 +355,7 @@ def detect(self) -> "Resource":
                 (
                     sys.version_info[:3]
                     if sys.version_info.releaselevel == "final"
-                    and not sys.version_info.serial
+                       and not sys.version_info.serial
                     else sys.version_info
                 ),
             )
@@ -471,10 +473,36 @@ def detect(self) -> "Resource":
         )
 
 
+class HostResourceDetector(ResourceDetector):
+    """
+       The HostResourceDetector detects host resources using OpenTelemetry.
+       """
+
+    def detect(self) -> "Resource":
+        try:
+            resource = Resource.get_empty()
+            host_name = socket.gethostname()
+            if host_name:
+                resource = resource.merge(Resource({HOST_NAME: host_name}))
+            host_arch = platform.machine()
+            if host_arch:
+                resource = resource.merge(Resource({HOST_ARCH: host_arch}))
+            return resource
+        except Exception as e:
+            logger.warning(
+                "%s Resource Detection failed silently: %s",
+                self.__class__.__name__,
+                e,
+            )
+            if self.raise_on_error:
+                raise e
+            return Resource.get_empty()
+
+
 def get_aggregated_resources(
-    detectors: typing.List["ResourceDetector"],
-    initial_resource: typing.Optional[Resource] = None,
-    timeout: int = 5,
+        detectors: typing.List["ResourceDetector"],
+        initial_resource: typing.Optional[Resource] = None,
+        timeout: int = 5,
 ) -> "Resource":
     """Retrieves resources from detectors in the order that they were passed
 

opentelemetry-sdk/tests/resources/test_resources.py

@@ -20,7 +20,9 @@
 from os import environ
 from unittest.mock import Mock, patch
 from urllib import parse
-
+from opentelemetry import trace as trace_api
+from opentelemetry.exporter.otlp.proto.grpc import exporter
+from opentelemetry.resource.detector.host import HostResourceDetector
 from opentelemetry.sdk.environment_variables import (
     OTEL_EXPERIMENTAL_RESOURCE_DETECTORS,
 )
@@ -54,6 +56,9 @@
     ResourceDetector,
     get_aggregated_resources,
 )
+from opentelemetry.sdk.trace import TracerProvider, export
+from opentelemetry.sdk.trace.export.in_memory_span_exporter import InMemorySpanExporter
+from opentelemetry.semconv.resource import ResourceAttributes
 
 try:
     import psutil
@@ -777,3 +782,27 @@ def test_os_detector_solaris(self):
 
         self.assertEqual(resource.attributes[OS_TYPE], "solaris")
         self.assertEqual(resource.attributes[OS_VERSION], "666.4.0.15.0")
+class TestHostResourceDetector(unittest.TestCase):
+    def test_host_resource_detector(self):
+        detector = HostResourceDetector()
+        actual = detector.detect()
+        self.assertTrue(actual.attributes.get(ResourceAttributes.HOST_NAME))
+        self.assertTrue(actual.attributes.get(ResourceAttributes.HOST_ARCH))
+
+    def test_host_resource_as_span_attribute(self):
+
+        tracer_provider = TracerProvider(resource=get_aggregated_resources([HostResourceDetector()]))
+        memory_exporter = InMemorySpanExporter()
+        span_processor = export.SimpleSpanProcessor(memory_exporter)
+        tracer_provider.add_span_processor(span_processor)
+        tracer = tracer_provider.get_tracer(__name__)
+
+        with tracer.start_as_current_span(
+                "test", kind=trace_api.SpanKind.SERVER
+        ) as _:
+            pass
+
+        span_list = memory_exporter.get_finished_spans()
+        self.assertTrue(span_list[0].resource.attributes.get(ResourceAttributes.HOST_NAME))
+        self.assertTrue(span_list[0].resource.attributes.get(ResourceAttributes.HOST_ARCH))
+