Skip to content

Commit 9a45fbf

Browse files
JamesNKJamesNK
committed
Initialize hosting trace with OTEL tags for sampling
1 parent 8a8dcbb commit 9a45fbf

File tree

5 files changed

+257
-98
lines changed

5 files changed

+257
-98
lines changed

‎src/Hosting/Hosting/src/Internal/HostingApplicationDiagnostics.cs‎

Lines changed: 55 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ internal sealed class HostingApplicationDiagnostics
3333
private readonly HostingEventSource _eventSource;
3434
private readonly HostingMetrics _metrics;
3535
private readonly ILogger _logger;
36+
private readonly bool _suppressActivityOpenTelemetryData;
3637

3738
public HostingApplicationDiagnostics(
3839
ILogger logger,
@@ -48,6 +49,7 @@ public HostingApplicationDiagnostics(
4849
_propagator = propagator;
4950
_eventSource = eventSource;
5051
_metrics = metrics;
52+
_suppressActivityOpenTelemetryData = AppContext.TryGetSwitch("Microsoft.AspNetCore.Hosting.SuppressActivityOpenTelemetryData", out var enabled) && enabled;
5153
}
5254

5355
[MethodImpl(MethodImplOptions.AggressiveInlining)]
@@ -88,9 +90,9 @@ public void BeginRequest(HttpContext httpContext, HostingApplication.Context con
8890
var diagnosticListenerActivityCreationEnabled = (diagnosticListenerEnabled && _diagnosticListener.IsEnabled(ActivityName, httpContext));
8991
var loggingEnabled = _logger.IsEnabled(LogLevel.Critical);
9092

91-
if (loggingEnabled || diagnosticListenerActivityCreationEnabled || _activitySource.HasListeners())
93+
if (ActivityCreator.IsActivityCreated(_activitySource, loggingEnabled || diagnosticListenerActivityCreationEnabled))
9294
{
93-
context.Activity = StartActivity(httpContext, loggingEnabled, diagnosticListenerActivityCreationEnabled, out var hasDiagnosticListener);
95+
context.Activity = StartActivity(httpContext, loggingEnabled || diagnosticListenerActivityCreationEnabled, out var hasDiagnosticListener);
9496
context.HasDiagnosticListener = hasDiagnosticListener;
9597

9698
if (context.Activity != null)
@@ -385,29 +387,17 @@ private void RecordRequestStartMetrics(HttpContext httpContext)
385387
}
386388

387389
[MethodImpl(MethodImplOptions.NoInlining)]
388-
private Activity? StartActivity(HttpContext httpContext, bool loggingEnabled, bool diagnosticListenerActivityCreationEnabled, out bool hasDiagnosticListener)
390+
private Activity? StartActivity(HttpContext httpContext, bool diagnosticsOrLoggingEnabled, out bool hasDiagnosticListener)
389391
{
392+
// StartActivity is only called if an Activity is already verified to be created.
393+
Debug.Assert(ActivityCreator.IsActivityCreated(_activitySource, diagnosticsOrLoggingEnabled),
394+
"Activity should only be created if diagnostics or logging is enabled.");
395+
390396
hasDiagnosticListener = false;
391397

392-
var tagsForCreation = new TagList();
393-
if (_activitySource.HasListeners() && httpContext.Request.Host.HasValue)
394-
{
395-
var host = httpContext.Request.Host.Host;
396-
var port = httpContext.Request.Host.Port;
397-
tagsForCreation.Add("server.address", host);
398-
if (port is not null)
399-
{
400-
tagsForCreation.Add("server.port", port);
401-
}
402-
else if (string.Equals("https", httpContext.Request.Scheme, StringComparison.OrdinalIgnoreCase))
403-
{
404-
tagsForCreation.Add("server.port", 443);
405-
}
406-
else if (string.Equals("http", httpContext.Request.Scheme, StringComparison.OrdinalIgnoreCase))
407-
{
408-
tagsForCreation.Add("server.port", 80);
409-
}
410-
}
398+
var initializeTags = !_suppressActivityOpenTelemetryData
399+
? CreateInitializeActivityTags(httpContext)
400+
: (TagList?)null;
411401

412402
var headers = httpContext.Request.Headers;
413403
var activity = ActivityCreator.CreateFromRemote(
@@ -422,9 +412,9 @@ private void RecordRequestStartMetrics(HttpContext httpContext)
422412
},
423413
ActivityName,
424414
ActivityKind.Server,
425-
tags: tagsForCreation,
415+
tags: initializeTags,
426416
links: null,
427-
loggingEnabled || diagnosticListenerActivityCreationEnabled);
417+
diagnosticsOrLoggingEnabled);
428418
if (activity is null)
429419
{
430420
return null;
@@ -445,6 +435,47 @@ private void RecordRequestStartMetrics(HttpContext httpContext)
445435
return activity;
446436
}
447437

438+
private static TagList CreateInitializeActivityTags(HttpContext httpContext)
439+
{
440+
// The tags here are set when the activity is created. They can be used in sampling decisions.
441+
// Most values in semantic conventions that are present at creation are specified:
442+
// https://github.com/open-telemetry/semantic-conventions/blob/27735ccca3746d7bb7fa061dfb73d93bcbae2b6e/docs/http/http-spans.md#L581-L592
443+
// Missing values recommended by the spec are:
444+
// - url.query (need configuration around redaction to do properly)
445+
// - http.request.header.<key>
446+
447+
var request = httpContext.Request;
448+
var creationTags = new TagList();
449+
450+
if (request.Host.HasValue)
451+
{
452+
creationTags.Add(HostingTelemetryHelpers.AttributeServerAddress, request.Host.Host);
453+
454+
if (HostingTelemetryHelpers.TryGetServerPort(request.Host, request.Scheme, out var port))
455+
{
456+
creationTags.Add(HostingTelemetryHelpers.AttributeServerPort, port);
457+
}
458+
}
459+
460+
HostingTelemetryHelpers.SetActivityHttpMethodTags(ref creationTags, request.Method);
461+
462+
if (request.Headers.TryGetValue("User-Agent", out var values))
463+
{
464+
var userAgent = values.Count > 0 ? values[0] : null;
465+
if (!string.IsNullOrEmpty(userAgent))
466+
{
467+
creationTags.Add(HostingTelemetryHelpers.AttributeUserAgentOriginal, userAgent);
468+
}
469+
}
470+
471+
creationTags.Add(HostingTelemetryHelpers.AttributeUrlScheme, request.Scheme);
472+
473+
var path = (request.PathBase.HasValue || request.Path.HasValue) ? (request.PathBase + request.Path).ToString() : "/";
474+
creationTags.Add(HostingTelemetryHelpers.AttributeUrlPath, path);
475+
476+
return creationTags;
477+
}
478+
448479
[MethodImpl(MethodImplOptions.NoInlining)]
449480
private void StopActivity(HttpContext httpContext, Activity activity, bool hasDiagnosticListener)
450481
{

‎src/Hosting/Hosting/src/Internal/HostingMetrics.cs‎

Lines changed: 3 additions & 72 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,7 @@
11
// Licensed to the .NET Foundation under one or more agreements.
22
// The .NET Foundation licenses this file to you under the MIT license.
33

4-
using System.Collections.Frozen;
54
using System.Diagnostics;
6-
using System.Diagnostics.CodeAnalysis;
75
using System.Diagnostics.Metrics;
86
using Microsoft.AspNetCore.Http;
97

@@ -55,7 +53,7 @@ public void RequestEnd(string protocol, string scheme, string method, string? ro
5553

5654
if (!disableHttpRequestDurationMetric && _requestDuration.Enabled)
5755
{
58-
if (TryGetHttpVersion(protocol, out var httpVersion))
56+
if (HostingTelemetryHelpers.TryGetHttpVersion(protocol, out var httpVersion))
5957
{
6058
tags.Add("network.protocol.version", httpVersion);
6159
}
@@ -65,7 +63,7 @@ public void RequestEnd(string protocol, string scheme, string method, string? ro
6563
}
6664

6765
// Add information gathered during request.
68-
tags.Add("http.response.status_code", GetBoxedStatusCode(statusCode));
66+
tags.Add("http.response.status_code", HostingTelemetryHelpers.GetBoxedStatusCode(statusCode));
6967
if (route != null)
7068
{
7169
tags.Add("http.route", route);
@@ -104,73 +102,6 @@ public void Dispose()
104102
private static void InitializeRequestTags(ref TagList tags, string scheme, string method)
105103
{
106104
tags.Add("url.scheme", scheme);
107-
tags.Add("http.request.method", ResolveHttpMethod(method));
108-
}
109-
110-
private static readonly object[] BoxedStatusCodes = new object[512];
111-
112-
private static object GetBoxedStatusCode(int statusCode)
113-
{
114-
object[] boxes = BoxedStatusCodes;
115-
return (uint)statusCode < (uint)boxes.Length
116-
? boxes[statusCode] ??= statusCode
117-
: statusCode;
118-
}
119-
120-
private static readonly FrozenDictionary<string, string> KnownMethods = FrozenDictionary.ToFrozenDictionary(new[]
121-
{
122-
KeyValuePair.Create(HttpMethods.Connect, HttpMethods.Connect),
123-
KeyValuePair.Create(HttpMethods.Delete, HttpMethods.Delete),
124-
KeyValuePair.Create(HttpMethods.Get, HttpMethods.Get),
125-
KeyValuePair.Create(HttpMethods.Head, HttpMethods.Head),
126-
KeyValuePair.Create(HttpMethods.Options, HttpMethods.Options),
127-
KeyValuePair.Create(HttpMethods.Patch, HttpMethods.Patch),
128-
KeyValuePair.Create(HttpMethods.Post, HttpMethods.Post),
129-
KeyValuePair.Create(HttpMethods.Put, HttpMethods.Put),
130-
KeyValuePair.Create(HttpMethods.Trace, HttpMethods.Trace)
131-
}, StringComparer.OrdinalIgnoreCase);
132-
133-
private static string ResolveHttpMethod(string method)
134-
{
135-
// TODO: Support configuration for configuring known methods
136-
if (KnownMethods.TryGetValue(method, out var result))
137-
{
138-
// KnownMethods ignores case. Use the value returned by the dictionary to have a consistent case.
139-
return result;
140-
}
141-
return "_OTHER";
142-
}
143-
144-
private static bool TryGetHttpVersion(string protocol, [NotNullWhen(true)] out string? version)
145-
{
146-
if (HttpProtocol.IsHttp11(protocol))
147-
{
148-
version = "1.1";
149-
return true;
150-
}
151-
if (HttpProtocol.IsHttp2(protocol))
152-
{
153-
// HTTP/2 only has one version.
154-
version = "2";
155-
return true;
156-
}
157-
if (HttpProtocol.IsHttp3(protocol))
158-
{
159-
// HTTP/3 only has one version.
160-
version = "3";
161-
return true;
162-
}
163-
if (HttpProtocol.IsHttp10(protocol))
164-
{
165-
version = "1.0";
166-
return true;
167-
}
168-
if (HttpProtocol.IsHttp09(protocol))
169-
{
170-
version = "0.9";
171-
return true;
172-
}
173-
version = null;
174-
return false;
105+
tags.Add("http.request.method", HostingTelemetryHelpers.GetNormalizedHttpMethod(method));
175106
}
176107
}

‎src/Hosting/Hosting/src/Internal/HostingTelemetryHelpers.cs‎

Lines changed: 132 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,132 @@
1+
// Licensed to the .NET Foundation under one or more agreements.
2+
// The .NET Foundation licenses this file to you under the MIT license.
3+
4+
using System.Collections.Frozen;
5+
using System.Diagnostics;
6+
using System.Diagnostics.CodeAnalysis;
7+
using Microsoft.AspNetCore.Http;
8+
9+
namespace Microsoft.AspNetCore.Hosting;
10+
11+
internal static class HostingTelemetryHelpers
12+
{
13+
// Semantic Conventions for HTTP.
14+
// Note: Not all telemetry code is using these const attribute names yet.
15+
public const string AttributeHttpRequestMethod = "http.request.method";
16+
public const string AttributeHttpRequestMethodOriginal = "http.request.method_original";
17+
public const string AttributeUrlScheme = "url.scheme";
18+
public const string AttributeUrlPath = "url.path";
19+
public const string AttributeServerAddress = "server.address";
20+
public const string AttributeServerPort = "server.port";
21+
public const string AttributeUserAgentOriginal = "user_agent.original";
22+
23+
// The value "_OTHER" is used for non-standard HTTP methods.
24+
// https://github.com/open-telemetry/semantic-conventions/blob/v1.23.0/docs/http/http-spans.md#common-attributes
25+
private const string OtherHttpMethod = "_OTHER";
26+
27+
private static readonly object[] BoxedStatusCodes = new object[512];
28+
29+
private static readonly FrozenDictionary<string, string> KnownHttpMethods = FrozenDictionary.ToFrozenDictionary([
30+
KeyValuePair.Create(HttpMethods.Connect, HttpMethods.Connect),
31+
KeyValuePair.Create(HttpMethods.Delete, HttpMethods.Delete),
32+
KeyValuePair.Create(HttpMethods.Get, HttpMethods.Get),
33+
KeyValuePair.Create(HttpMethods.Head, HttpMethods.Head),
34+
KeyValuePair.Create(HttpMethods.Options, HttpMethods.Options),
35+
KeyValuePair.Create(HttpMethods.Patch, HttpMethods.Patch),
36+
KeyValuePair.Create(HttpMethods.Post, HttpMethods.Post),
37+
KeyValuePair.Create(HttpMethods.Put, HttpMethods.Put),
38+
KeyValuePair.Create(HttpMethods.Trace, HttpMethods.Trace)
39+
], StringComparer.OrdinalIgnoreCase);
40+
41+
// Boxed port values for HTTP and HTTPS.
42+
private static readonly object HttpPort = 80;
43+
private static readonly object HttpsPort = 443;
44+
45+
public static bool TryGetServerPort(HostString host, string scheme, [NotNullWhen(true)] out object? port)
46+
{
47+
if (host.Port.HasValue)
48+
{
49+
port = host.Port.Value;
50+
return true;
51+
}
52+
53+
// If the port is not specified, use the default port for the scheme.
54+
if (string.Equals(scheme, "http", StringComparison.OrdinalIgnoreCase))
55+
{
56+
port = HttpPort;
57+
return true;
58+
}
59+
else if (string.Equals(scheme, "https", StringComparison.OrdinalIgnoreCase))
60+
{
61+
port = HttpsPort;
62+
return true;
63+
}
64+
65+
// Unknown scheme, no default port.
66+
port = null;
67+
return false;
68+
}
69+
70+
public static object GetBoxedStatusCode(int statusCode)
71+
{
72+
object[] boxes = BoxedStatusCodes;
73+
return (uint)statusCode < (uint)boxes.Length
74+
? boxes[statusCode] ??= statusCode
75+
: statusCode;
76+
}
77+
78+
public static string GetNormalizedHttpMethod(string method)
79+
{
80+
// TODO: Support configuration for configuring known methods
81+
if (method != null && KnownHttpMethods.TryGetValue(method, out var result))
82+
{
83+
// KnownHttpMethods ignores case. Use the value returned by the dictionary to have a consistent case.
84+
return result;
85+
}
86+
return OtherHttpMethod;
87+
}
88+
89+
public static bool TryGetHttpVersion(string protocol, [NotNullWhen(true)] out string? version)
90+
{
91+
if (HttpProtocol.IsHttp11(protocol))
92+
{
93+
version = "1.1";
94+
return true;
95+
}
96+
if (HttpProtocol.IsHttp2(protocol))
97+
{
98+
// HTTP/2 only has one version.
99+
version = "2";
100+
return true;
101+
}
102+
if (HttpProtocol.IsHttp3(protocol))
103+
{
104+
// HTTP/3 only has one version.
105+
version = "3";
106+
return true;
107+
}
108+
if (HttpProtocol.IsHttp10(protocol))
109+
{
110+
version = "1.0";
111+
return true;
112+
}
113+
if (HttpProtocol.IsHttp09(protocol))
114+
{
115+
version = "0.9";
116+
return true;
117+
}
118+
version = null;
119+
return false;
120+
}
121+
122+
public static void SetActivityHttpMethodTags(ref TagList tags, string originalHttpMethod)
123+
{
124+
var normalizedHttpMethod = GetNormalizedHttpMethod(originalHttpMethod);
125+
tags.Add(AttributeHttpRequestMethod, normalizedHttpMethod);
126+
127+
if (originalHttpMethod != normalizedHttpMethod)
128+
{
129+
tags.Add(AttributeHttpRequestMethodOriginal, originalHttpMethod);
130+
}
131+
}
132+
}

0 commit comments

Comments
 (0)