[Instrumentation.Http] Skip tagging traces when running on .NET 9+

global.json

@@ -1,6 +1,6 @@
 {
   "sdk": {
     "rollForward": "latestFeature",
-    "version": "8.0.100"
+    "version": "9.0.100-rc.2.24474.11"
   }
 }

src/OpenTelemetry.Instrumentation.Http/Implementation/HttpHandlerDiagnosticListener.cs

@@ -35,6 +35,8 @@
     private static readonly PropertyFetcher<HttpResponseMessage> StopResponseFetcher = new("Response");
     private static readonly PropertyFetcher<Exception> StopExceptionFetcher = new("Exception");
     private static readonly PropertyFetcher<TaskStatus> StopRequestStatusFetcher = new("RequestTaskStatus");
+    private static readonly bool Net9orGreater = Environment.Version.Major >= 9;
+
     private readonly HttpClientTraceInstrumentationOptions options;
 
     public HttpHandlerDiagnosticListener(HttpClientTraceInstrumentationOptions options)
@@ -135,10 +137,13 @@
                 ActivityInstrumentationHelper.SetKindProperty(activity, ActivityKind.Client);
             }
 
-            // see the spec https://github.com/open-telemetry/semantic-conventions/blob/v1.23.0/docs/http/http-spans.md
-            HttpTagHelper.RequestDataHelper.SetHttpMethodTag(activity, request.Method.Method);
+            if (!Net9orGreater)
+            {
+                // see the spec https://github.com/open-telemetry/semantic-conventions/blob/v1.23.0/docs/http/http-spans.md
+                HttpTagHelper.RequestDataHelper.SetHttpMethodTag(activity, request.Method.Method);
+            }
 
-            if (request.RequestUri != null)
+            if (!Net9orGreater && request.RequestUri != null)
             {
                 activity.SetTag(SemanticConventions.AttributeServerAddress, request.RequestUri.Host);
                 activity.SetTag(SemanticConventions.AttributeServerPort, request.RequestUri.Port);
@@ -199,16 +204,19 @@
 
             if (TryFetchResponse(payload, out var response))
             {
-                if (currentStatusCode == ActivityStatusCode.Unset)
+                if (!Net9orGreater)
                 {
-                    activity.SetStatus(SpanHelper.ResolveActivityStatusForHttpStatusCode(activity.Kind, (int)response.StatusCode));
-                }
+                    if (currentStatusCode == ActivityStatusCode.Unset)
+                    {
+                        activity.SetStatus(SpanHelper.ResolveActivityStatusForHttpStatusCode(activity.Kind, (int)response.StatusCode));
+                    }
 
-                activity.SetTag(SemanticConventions.AttributeNetworkProtocolVersion, RequestDataHelper.GetHttpProtocolVersion(response.Version));
-                activity.SetTag(SemanticConventions.AttributeHttpResponseStatusCode, TelemetryHelper.GetBoxedStatusCode(response.StatusCode));
-                if (activity.Status == ActivityStatusCode.Error)
-                {
-                    activity.SetTag(SemanticConventions.AttributeErrorType, TelemetryHelper.GetStatusCodeString(response.StatusCode));
+                    activity.SetTag(SemanticConventions.AttributeNetworkProtocolVersion, RequestDataHelper.GetHttpProtocolVersion(response.Version));
+                    activity.SetTag(SemanticConventions.AttributeHttpResponseStatusCode, TelemetryHelper.GetBoxedStatusCode(response.StatusCode));
+                    if (activity.Status == ActivityStatusCode.Error)
+                    {
+                        activity.SetTag(SemanticConventions.AttributeErrorType, TelemetryHelper.GetStatusCodeString(response.StatusCode));
+                    }
                 }
 
                 try
@@ -302,7 +310,7 @@
         // https://learn.microsoft.com/dotnet/api/system.net.http.httprequesterror?view=net-8.0
         if (exc is HttpRequestException httpRequestException)
         {
             return httpRequestException.HttpRequestError switch
             {
                 HttpRequestError.NameResolutionError => "name_resolution_error",
                 HttpRequestError.ConnectionError => "connection_error",

src/OpenTelemetry.Instrumentation.Http/Implementation/HttpHandlerMetricsDiagnosticListener.cs

@@ -28,6 +28,7 @@ internal sealed class HttpHandlerMetricsDiagnosticListener : ListenerHandler
     private static readonly PropertyFetcher<HttpResponseMessage> StopResponseFetcher = new("Response");
     private static readonly PropertyFetcher<Exception> StopExceptionFetcher = new("Exception");
     private static readonly PropertyFetcher<HttpRequestMessage> RequestFetcher = new("Request");
+    private static readonly bool Net9orGreater = Environment.Version.Major >= 9;
 #if NET
     private static readonly HttpRequestOptionsKey<string?> HttpRequestOptionsErrorKey = new(SemanticConventions.AttributeErrorType);
 #endif
@@ -39,7 +40,7 @@ public HttpHandlerMetricsDiagnosticListener(string name)
 
     public static void OnStopEventWritten(Activity activity, object? payload)
     {
-        if (TryFetchRequest(payload, out var request))
+        if (!Net9orGreater && TryFetchRequest(payload, out var request))
         {
             // see the spec https://github.com/open-telemetry/semantic-conventions/blob/v1.23.0/docs/http/http-metrics.md
             TagList tags = default;

src/OpenTelemetry.Instrumentation.Http/OpenTelemetry.Instrumentation.Http.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>$(NetMinimumSupportedVersion);$(NetStandardMinimumSupportedVersion)</TargetFrameworks>
+    <TargetFrameworks>net9.0;$(NetMinimumSupportedVersion);$(NetStandardMinimumSupportedVersion)</TargetFrameworks>
     <TargetFrameworks Condition="$(OS) == 'Windows_NT'">$(TargetFrameworks);$(NetFrameworkMinimumSupportedVersion)</TargetFrameworks>
     <Description>Http instrumentation for OpenTelemetry .NET.</Description>
     <PackageTags>$(PackageTags);distributed-tracing</PackageTags>

test/OpenTelemetry.Instrumentation.Http.Tests/HttpClientTests.Basic.cs

@@ -425,6 +425,18 @@ public async Task HttpRequestMethodIsSetOnActivityAsPerSpec(string originalMetho
         }
 
         Assert.Equal(expectedMethod, activity.GetTagValue(SemanticConventions.AttributeHttpRequestMethod));
+
+#if NET9_0_OR_GREATER
+        if (expectedOriginalMethod != null && expectedOriginalMethod != "CUSTOM")
+        {
+            // TODO: NEED TO REVIEW THE SPEC.
+            // "http.request.method_original" is only set when the HTTP Method is not a standard HTTP method.
+
+            // Our implementation expects HTTP Methods to be in uppercase. "GET" is known but "Get" is unknown.
+            // In contrast, NET9 is case-insensitive. "GET" and "Get" are both known.
+            expectedOriginalMethod = null;
+        }
+#endif
         Assert.Equal(expectedOriginalMethod, activity.GetTagValue(SemanticConventions.AttributeHttpRequestMethodOriginal));
     }
 
@@ -727,7 +739,17 @@ public async Task ValidateUrlQueryRedaction(string urlQuery, string expectedUrlQ
         var activity = exportedItems[0];
 
         var expectedUrl = $"{this.url}path{expectedUrlQuery}";
+
+#if NET9_0_OR_GREATER
+
+        // TODO: NEED TO UPDATE THIS TEST TO USE .NET'S SETTING TO DISABLE REDACTION.
+        // CURRENTLY THIS DOESN'T WORK WITH OUR TESTS WHICH RUN IN PARALLEL.
+        // https://github.com/dotnet/docs/issues/42792
+        expectedUrl = $"{this.url}path?*";
         Assert.Equal(expectedUrl, activity.GetTagValue(SemanticConventions.AttributeUrlFull));
+#else
+        Assert.Equal(expectedUrl, activity.GetTagValue(SemanticConventions.AttributeUrlFull));
+#endif
     }
 
     [Theory]

test/OpenTelemetry.Instrumentation.Http.Tests/HttpClientTests.cs

@@ -340,7 +340,21 @@ private static async Task HttpOutCallsAreCollectedSuccessfullyBodyAsync(
             Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeHttpRequestMethod && kvp.Value?.ToString() == normalizedAttributesTestCase[SemanticConventions.AttributeHttpRequestMethod]);
             Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeServerAddress && kvp.Value?.ToString() == normalizedAttributesTestCase[SemanticConventions.AttributeServerAddress]);
             Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeServerPort && kvp.Value?.ToString() == normalizedAttributesTestCase[SemanticConventions.AttributeServerPort]);
+
+#if NET9_0_OR_GREATER
+            // NET9 does not record the URL Fragment Identifier.
+            var expected = normalizedAttributesTestCase[SemanticConventions.AttributeUrlFull];
+            if (expected.EndsWith("#fragment", StringComparison.Ordinal))
+            {
+                // remove fragment from expected value
+                expected = expected.Substring(0, expected.Length - "#fragment".Length);
+            }
+
+            Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeUrlFull && kvp.Value?.ToString() == expected);
+#else
             Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeUrlFull && kvp.Value?.ToString() == normalizedAttributesTestCase[SemanticConventions.AttributeUrlFull]);
+#endif
+
             if (tc.ResponseExpected)
             {
                 Assert.Contains(normalizedAttributes, kvp => kvp.Key == SemanticConventions.AttributeNetworkProtocolVersion && kvp.Value?.ToString() == normalizedAttributesTestCase[SemanticConventions.AttributeNetworkProtocolVersion]);

test/OpenTelemetry.Instrumentation.Http.Tests/OpenTelemetry.Instrumentation.Http.Tests.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>$(SupportedNetTargets)</TargetFrameworks>
+    <TargetFrameworks>net9.0;$(SupportedNetTargets)</TargetFrameworks>
     <TargetFrameworks Condition="$(OS) == 'Windows_NT'">$(TargetFrameworks);$(NetFrameworkMinimumSupportedVersion)</TargetFrameworks>
     <Description>Unit test project for OpenTelemetry HTTP instrumentations.</Description>
   </PropertyGroup>