add Azure container resource provider

Author: zeitlinger

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureAppServiceResourceProvider.java

@@ -58,10 +58,9 @@ public Resource createResource(ConfigProperties config) {
       return Resource.empty();
     }
     String name = Objects.requireNonNull(env.get(WEBSITE_SITE_NAME));
-    AttributesBuilder builder = AzureVmResourceProvider.azureAttributeBuilder();
-    builder.put(
-        ResourceAttributes.CLOUD_PLATFORM,
-        ResourceAttributes.CloudPlatformValues.AZURE_APP_SERVICE);
+    AttributesBuilder builder =
+        AzureVmResourceProvider.azureAttributeBuilder(
+            ResourceAttributes.CloudPlatformValues.AZURE_APP_SERVICE);
     builder.put(ResourceAttributes.SERVICE_NAME, name);
 
     String resourceUri = resourceUri(name);

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureContainersResourceProvider.java

@@ -0,0 +1,57 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.contrib.azure.resource;
+
+import io.opentelemetry.api.common.AttributeKey;
+import io.opentelemetry.api.common.AttributesBuilder;
+import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
+import io.opentelemetry.sdk.resources.Resource;
+import io.opentelemetry.semconv.ResourceAttributes;
+import java.util.HashMap;
+import java.util.Map;
+
+public class AzureContainersResourceProvider extends CloudResourceProvider {
+
+  static final String CONTAINER_APP_NAME = "CONTAINER_APP_NAME";
+
+  private static final String CONTAINER_APP_REPLICA_NAME = "CONTAINER_APP_REPLICA_NAME";
+  private static final String CONTAINER_APP_REVISION = "CONTAINER_APP_REVISION";
+
+  private static final Map<AttributeKey<String>, String> ENV_VAR_MAPPING = new HashMap<>();
+
+  static {
+    ENV_VAR_MAPPING.put(ResourceAttributes.SERVICE_NAME, CONTAINER_APP_NAME);
+    ENV_VAR_MAPPING.put(ResourceAttributes.SERVICE_INSTANCE_ID, CONTAINER_APP_REPLICA_NAME);
+    ENV_VAR_MAPPING.put(ResourceAttributes.SERVICE_VERSION, CONTAINER_APP_REVISION);
+  }
+
+  private final Map<String, String> env;
+
+  // SPI
+  public AzureContainersResourceProvider() {
+    this(System.getenv());
+  }
+
+  // Visible for testing
+  AzureContainersResourceProvider(Map<String, String> env) {
+    this.env = env;
+  }
+
+  @Override
+  public Resource createResource(ConfigProperties config) {
+    AzureEnvVarPlatform detect = AzureEnvVarPlatform.detect(env);
+    if (detect != AzureEnvVarPlatform.CONTAINERS) {
+      return Resource.empty();
+    }
+
+    AttributesBuilder builder =
+        AzureVmResourceProvider.azureAttributeBuilder("azure_container_apps");
+
+    AzureEnvVarPlatform.addAttributesFromEnv(ENV_VAR_MAPPING, env, builder);
+
+    return Resource.create(builder.build());
+  }
+}

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureEnvVarPlatform.java

@@ -12,9 +12,14 @@
 public enum AzureEnvVarPlatform {
   APP_SERVICE,
   FUNCTIONS,
+  CONTAINERS,
   NONE;
 
   static AzureEnvVarPlatform detect(Map<String, String> env) {
+    String appName = env.get(AzureContainersResourceProvider.CONTAINER_APP_NAME);
+    if (appName != null) {
+      return CONTAINERS;
+    }
     String name = env.get(AzureAppServiceResourceProvider.WEBSITE_SITE_NAME);
     if (name == null) {
       return NONE;

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureFunctionsResourceProvider.java

@@ -49,9 +49,9 @@ public Resource createResource(ConfigProperties config) {
       return Resource.empty();
     }
 
-    AttributesBuilder builder = AzureVmResourceProvider.azureAttributeBuilder();
-    builder.put(
-        ResourceAttributes.CLOUD_PLATFORM, ResourceAttributes.CloudPlatformValues.AZURE_FUNCTIONS);
+    AttributesBuilder builder =
+        AzureVmResourceProvider.azureAttributeBuilder(
+            ResourceAttributes.CloudPlatformValues.AZURE_FUNCTIONS);
 
     String limit = env.get(FUNCTIONS_MEM_LIMIT);
     if (limit != null) {

azure-resources/src/main/java/io/opentelemetry/contrib/azure/resource/AzureVmResourceProvider.java

@@ -69,8 +69,8 @@ public Resource createResource(ConfigProperties config) {
   }
 
   private static Resource parseMetadata(String body) {
-    AttributesBuilder builder = azureAttributeBuilder();
-    builder.put(ResourceAttributes.CLOUD_PLATFORM, ResourceAttributes.CloudPlatformValues.AZURE_VM);
+    AttributesBuilder builder =
+        azureAttributeBuilder(ResourceAttributes.CloudPlatformValues.AZURE_VM);
     try (JsonParser parser = JSON_FACTORY.createParser(body)) {
       parser.nextToken();
       parseResponse(parser, builder);
@@ -81,9 +81,10 @@ private static Resource parseMetadata(String body) {
   }
 
   @NotNull
-  static AttributesBuilder azureAttributeBuilder() {
+  static AttributesBuilder azureAttributeBuilder(String platform) {
     AttributesBuilder builder = Attributes.builder();
     builder.put(ResourceAttributes.CLOUD_PROVIDER, ResourceAttributes.CloudProviderValues.AZURE);
+    builder.put(ResourceAttributes.CLOUD_PLATFORM, platform);
     return builder;
   }
 

azure-resources/src/test/java/io/opentelemetry/contrib/azure/resource/AzureContainersResourceProviderTest.java

@@ -0,0 +1,51 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.contrib.azure.resource;
+
+import com.google.common.collect.ImmutableMap;
+import io.opentelemetry.sdk.testing.assertj.AttributesAssert;
+import io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions;
+import io.opentelemetry.semconv.ResourceAttributes;
+import java.util.HashMap;
+import java.util.Map;
+import org.jetbrains.annotations.NotNull;
+import org.junit.jupiter.api.Test;
+
+class AzureContainersResourceProviderTest {
+  private static final String TEST_APP_NAME = "TEST_APP_NAME";
+  private static final String TEST_REPLICA_NAME = "TEST_REPLICA_NAME";
+  private static final String TEST_REVISION = "TEST_REVISION";
+
+  private static final ImmutableMap<String, String> DEFAULT_ENV_VARS =
+      ImmutableMap.of(
+          "CONTAINER_APP_NAME", TEST_APP_NAME,
+          "CONTAINER_APP_REPLICA_NAME", TEST_REPLICA_NAME,
+          "CONTAINER_APP_REVISION", TEST_REVISION);
+
+  @Test
+  void defaultValues() {
+    createResource(DEFAULT_ENV_VARS)
+        .containsEntry(ResourceAttributes.CLOUD_PROVIDER, "azure")
+        .containsEntry(ResourceAttributes.CLOUD_PLATFORM, "azure_container_apps")
+        .containsEntry(ResourceAttributes.SERVICE_NAME, TEST_APP_NAME)
+        .containsEntry(ResourceAttributes.SERVICE_INSTANCE_ID, TEST_REPLICA_NAME)
+        .containsEntry(ResourceAttributes.SERVICE_VERSION, TEST_REVISION);
+  }
+
+  @Test
+  void isNotContainer() {
+    HashMap<String, String> map = new HashMap<>(DEFAULT_ENV_VARS);
+    map.remove("CONTAINER_APP_NAME");
+
+    createResource(map).isEmpty();
+  }
+
+  @NotNull
+  private static AttributesAssert createResource(Map<String, String> map) {
+    return OpenTelemetryAssertions.assertThat(
+        new AzureContainersResourceProvider(map).createResource(null).getAttributes());
+  }
+}