fixed the incorrect use of Resource creation

Author: Sanket-0510

docs/examples/opencensus-shim/app.py

@@ -22,7 +22,7 @@
     OTLPSpanExporter,
 )
 from opentelemetry.instrumentation.sqlite3 import SQLite3Instrumentor
-from opentelemetry.sdk.resources import Resource
+from opentelemetry.sdk.resources import SERVICE_NAME, Resource
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import BatchSpanProcessor
 from opentelemetry.shim.opencensus import install_shim
@@ -31,9 +31,9 @@
 
 # Set up OpenTelemetry
 tracer_provider = TracerProvider(
-    resource=Resource(
+    resource=Resource.create(
         {
-            "service.name": "opencensus-shim-example-flask",
+            SERVICE_NAME: "opencensus-shim-example-flask",
         }
     )
 )

exporter/opentelemetry-exporter-otlp-proto-common/src/opentelemetry/exporter/otlp/proto/common/_internal/__init__.py

@@ -66,7 +66,9 @@ def _encode_instrumentation_scope(
 
 
 def _encode_resource(resource: Resource) -> PB2Resource:
-    return PB2Resource(attributes=_encode_attributes(resource.attributes))
+    return PB2Resource.create(
+        attributes=_encode_attributes(resource.attributes)
+    )
 
 
 def _encode_value(
@@ -165,7 +167,7 @@ def _get_resource_data(
         sdk_resource,
         scope_data,
     ) in sdk_resource_scope_data.items():
-        collector_resource = PB2Resource(
+        collector_resource = PB2Resource.create(
             attributes=_encode_attributes(sdk_resource.attributes)
         )
         resource_data.append(

exporter/opentelemetry-exporter-otlp-proto-common/src/opentelemetry/exporter/otlp/proto/common/_internal/metrics_encoder/__init__.py

@@ -200,7 +200,7 @@ def encode_metrics(data: MetricsData) -> ExportMetricsServiceRequest:
     ) in resource_metrics_dict.items():
         resource_data.append(
             pb2.ResourceMetrics(
-                resource=PB2Resource(
+                resource=PB2Resource.create(
                     attributes=_encode_attributes(sdk_resource.attributes)
                 ),
                 scope_metrics=scope_data.values(),

exporter/opentelemetry-exporter-otlp-proto-grpc/src/opentelemetry/exporter/otlp/proto/grpc/__init__.py

@@ -44,14 +44,14 @@
 
     from opentelemetry import trace
     from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
-    from opentelemetry.sdk.resources import Resource
+    from opentelemetry.sdk.resources import SERVICE_NAME, Resource
     from opentelemetry.sdk.trace import TracerProvider
     from opentelemetry.sdk.trace.export import BatchSpanProcessor
 
     # Resource can be required for some backends, e.g. Jaeger
     # If resource wouldn't be set - traces wouldn't appears in Jaeger
-    resource = Resource(attributes={
-        "service.name": "service"
+    resource = Resource.create(attributes={
+            SERVICE_NAME: "service"
     })
 
     trace.set_tracer_provider(TracerProvider(resource=resource))

exporter/opentelemetry-exporter-otlp-proto-http/src/opentelemetry/exporter/otlp/proto/http/__init__.py

@@ -44,14 +44,14 @@
 
     from opentelemetry import trace
     from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
-    from opentelemetry.sdk.resources import Resource
+    from opentelemetry.sdk.resources import SERVICE_NAME, Resource
     from opentelemetry.sdk.trace import TracerProvider
     from opentelemetry.sdk.trace.export import BatchSpanProcessor
 
     # Resource can be required for some backends, e.g. Jaeger
     # If resource wouldn't be set - traces wouldn't appears in Jaeger
-    resource = Resource(attributes={
-        "service.name": "service"
+    resource = Resource.create(attributes={
+        SERVICE_NAME: "service"
     })
 
     trace.set_tracer_provider(TracerProvider(resource=resource))

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

@@ -222,7 +222,7 @@ def create(
                 continue
         resource = get_aggregated_resources(
             resource_detectors, _DEFAULT_RESOURCE
-        ).merge(Resource(attributes, schema_url))
+        ).merge(Resource.create(attributes, schema_url))
 
         if not resource.attributes.get(SERVICE_NAME, None):
             default_service_name = "unknown_service"
@@ -233,7 +233,9 @@ def create(
             if process_executable_name:
                 default_service_name += ":" + process_executable_name
             resource = resource.merge(
-                Resource({SERVICE_NAME: default_service_name}, schema_url)
+                Resource.create(
+                    {SERVICE_NAME: default_service_name}, schema_url
+                )
             )
         return resource
 
@@ -282,7 +284,7 @@ def merge(self, other: "Resource") -> "Resource":
                 other.schema_url,
             )
             return self
-        return Resource(merged_attributes, schema_url)  # type: ignore
+        return Resource.create(merged_attributes, schema_url)  # type: ignore
 
     def __eq__(self, other: object) -> bool:
         if not isinstance(other, Resource):
@@ -310,8 +312,8 @@ def to_json(self, indent: Optional[int] = 4) -> str:
         )
 
 
-_EMPTY_RESOURCE = Resource({})
-_DEFAULT_RESOURCE = Resource(
+_EMPTY_RESOURCE = Resource.create({})
+_DEFAULT_RESOURCE = Resource.create(
     {
         TELEMETRY_SDK_LANGUAGE: "python",
         TELEMETRY_SDK_NAME: "opentelemetry",
@@ -353,7 +355,7 @@ def detect(self) -> "Resource":
         service_name = environ.get(OTEL_SERVICE_NAME)
         if service_name:
             env_resource_map[SERVICE_NAME] = service_name
-        return Resource(env_resource_map)
+        return Resource.create(env_resource_map)
 
 
 class ProcessResourceDetector(ResourceDetector):
@@ -396,7 +398,7 @@ def detect(self) -> "Resource":
             username = process.username()
             resource_info[PROCESS_OWNER] = username
 
-        return Resource(resource_info)  # type: ignore
+        return Resource.create(resource_info)  # type: ignore
 
 
 class OsResourceDetector(ResourceDetector):
@@ -475,7 +477,7 @@ def detect(self) -> "Resource":
             os_type = "solaris"
             os_version = platform.version()
 
-        return Resource(
+        return Resource.create(
             {
                 OS_TYPE: os_type,
                 OS_VERSION: os_version,
@@ -489,7 +491,7 @@ class _HostResourceDetector(ResourceDetector):
     """
 
     def detect(self) -> "Resource":
-        return Resource(
+        return Resource.create(
             {
                 HOST_NAME: socket.gethostname(),
                 HOST_ARCH: platform.machine(),

tests/opentelemetry-test-utils/src/opentelemetry/test/spantestutil.py

@@ -45,7 +45,7 @@ def get_span_with_dropped_attributes_events_links():
 
     tracer = new_tracer(
         span_limits=trace_sdk.SpanLimits(),
-        resource=Resource(attributes=attributes),
+        resource=Resource.create(attributes=attributes),
     )
     with tracer.start_as_current_span(
         "span", links=links, attributes=attributes