Add configurable business tracing profile

framework/docs/aspects/README.md

@@ -61,6 +61,8 @@ Request → [Trace] → [Log] → [UnitOfWork] → Method → [UnitOfWork] → [
 Integrates with OpenTelemetry to create spans for method execution.
 
 ```csharp
+using BBT.Aether.Telemetry;
+
 // Basic span creation
 [Trace]
 public async Task ProcessAsync() { }
@@ -77,6 +79,10 @@ public async Task ProcessAsync() { }
 [Trace(Mode = TracingMode.Span)]     // Creates new span (default)
 [Trace(Mode = TracingMode.Event)]    // Adds events to current span
 [Trace(Mode = TracingMode.Enrich)]   // Enriches current span with tags
+
+// Trace aspects represent application/business spans in both profiles
+[Trace]
+public async Task ExecuteDiagnosticStepAsync() { }
 ```
 
 **Properties:**
@@ -85,6 +91,8 @@ public async Task ProcessAsync() { }
 - `OperationName` - Custom span name (default: ClassName.MethodName)
 - `Tags` - Custom tags in "key:value" format
 
+`[Trace]` annotations represent application/business spans and are emitted in both `Business` and `Verbose`. In the `Business` profile, completed spans whose final display name starts with `[` are filtered as ordered pipeline-step detail. `Telemetry:Tracing:DetailLevel` also controls diagnostic instrumentation such as EF Core, distributed cache/lock, and low-level client spans globally.
+
 ### [Log] - Structured Logging
 
 Adds method entry/exit logging with performance tracking and enrichment.
@@ -260,4 +268,3 @@ public class OrderAppService
 
 - [Unit of Work](../unit-of-work/README.md) - Detailed UoW documentation
 - [Telemetry](../telemetry/README.md) - OpenTelemetry setup
-

framework/docs/telemetry/README.md

@@ -64,8 +64,10 @@ Config section key: `Telemetry` or `Aether:Telemetry`.
       "Protocol": "http/protobuf"
     },
     "Tracing": {
+      "DetailLevel": "Business",
       "EnableAspNetCore": true,
       "EnableHttpClient": true,
+      "EnableEntityFrameworkCore": true,
       "AdditionalSources": ["MyApp.*"],
       "ExcludedPaths": ["/health", "/metrics"],
       "Headers": ["x-correlation-id", "x-request-id"],
@@ -105,6 +107,7 @@ Config section key: `Telemetry` or `Aether:Telemetry`.
 }
 ```
 
+- **Tracing.DetailLevel**: `Business` is the default and keeps service boundaries and `[Trace]` application/business spans while suppressing diagnostic instrumentation such as EF Core, distributed cache/lock, low-level Dapr calls, and spans whose final display name starts with `[` (ordered pipeline-step detail). `Verbose` keeps all configured instrumentation and must be selected explicitly.
 - **Tracing.Headers**: Request header names added as activity tags on spans (no wildcard).
 - **Logging.Enrichers**: CustomAttributes and Headers are added as attributes to **all** log records (via EnricherLogProcessor) and to the HTTP body log event (via middleware scope). Header values in the sensitive list are redacted.
 - **Logging.Body**: Options for HTTP request/response body logging when `UseHttpBodyLogging()` is used. Path exclusion uses `Logging.ExcludedPaths`.
@@ -143,6 +146,9 @@ var response = await _httpClient.GetAsync("https://api.example.com/products");
 var product = await _repository.GetAsync(id);
 ```
 
+Custom static instrumentation can use `AetherTracingRuntime.IsVerbose` to
+follow the same globally configured profile.
+
 ### Custom Spans with Aspects
 
 ```csharp
@@ -508,4 +514,3 @@ public class OrderServiceTests
 - **[Application Services](../application-services/README.md)** - Automatically traced
 - **[Unit of Work](../unit-of-work/README.md)** - Transaction spans
 - **[Distributed Events](../distributed-events/README.md)** - Context propagation
-

framework/src/BBT.Aether.AspNetCore/BBT/Aether/AspNetCore/Telemetry/BusinessSpanFilterProcessor.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Diagnostics;
+using OpenTelemetry;
+
+namespace BBT.Aether.AspNetCore.Telemetry;
+
+/// <summary>
+/// Removes pipeline-detail spans from the export path when the Business tracing profile is active.
+/// </summary>
+/// <remarks>
+/// Pipeline steps assign their final display names while the activity is running, so this filter
+/// must run on completion rather than at sampling time. Clearing the recorded flag allows the
+/// standard OpenTelemetry activity export processors to skip the span while preserving its
+/// in-process activity context for any child operations created during execution.
+/// </remarks>
+internal sealed class BusinessSpanFilterProcessor : BaseProcessor<Activity>
+{
+    public override void OnEnd(Activity activity)
+    {
+        ArgumentNullException.ThrowIfNull(activity);
+
+        if (activity.DisplayName.StartsWith("[", StringComparison.Ordinal))
+        {
+            activity.ActivityTraceFlags &= ~ActivityTraceFlags.Recorded;
+        }
+    }
+}

framework/src/BBT.Aether.AspNetCore/BBT/Aether/AspNetCore/Telemetry/TelemetryOptions.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using BBT.Aether.Telemetry;
 
 namespace BBT.Aether.AspNetCore.Telemetry;
 
@@ -113,6 +114,12 @@ public sealed class LoggingEnricherOptions
 
 public sealed class AetherTracingOptions
 {
+    /// <summary>
+    /// Controls whether only business spans or all diagnostic spans are produced.
+    /// Defaults to Business to keep production traces focused on service boundaries and business spans.
+    /// </summary>
+    public AetherTracingDetailLevel DetailLevel { get; set; } = AetherTracingDetailLevel.Business;
+
     public bool EnableAspNetCore { get; set; } = true;
     public bool EnableHttpClient { get; set; } = true;
     public bool EnableEntityFrameworkCore { get; set; } = true;

framework/src/BBT.Aether.AspNetCore/Microsoft/Extensions/DependencyInjection/AetherTelemetryServiceCollectionExtensions.cs

@@ -2,9 +2,11 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
+using System.Net.Http;
 using System.Reflection;
 using System.Text.RegularExpressions;
 using BBT.Aether.AspNetCore.Telemetry;
+using BBT.Aether.Telemetry;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Routing;
 using Microsoft.Extensions.Configuration;
@@ -20,7 +22,7 @@
 
 public static class AetherTelemetryServiceCollectionExtensions
 {
     public static IServiceCollection AddAetherTelemetry(
         this IServiceCollection services,
         IConfiguration configuration,
         IHostEnvironment? environment = null,
@@ -37,6 +39,7 @@
         }
 
         section.Bind(opts);
+        AetherTracingRuntime.Configure(opts.Tracing.DetailLevel);
 
         // Apply defaults and environment variables
         var envName =
@@ -50,7 +53,7 @@
         opts.ServiceName ??=
             Environment.GetEnvironmentVariable("OTEL_SERVICE_NAME")
             ?? configuration["ApplicationName"]
             ?? "aether";
 
         // Service version: config > entry assembly version > "1.0.0"
         opts.ServiceVersion ??= serviceVersion;
@@ -82,7 +85,7 @@
             {
                 resource
                     .AddService(
                         serviceName: opts.ServiceName!,
                         serviceVersion: opts.ServiceVersion,
                         serviceInstanceId: Environment.MachineName)
                     .AddAttributes(new Dictionary<string, object>
@@ -156,18 +159,23 @@
                 {
                     tracing.AddHttpClientInstrumentation(o =>
                     {
-                        o.FilterHttpRequestMessage = req =>
-                            !IsExcluded(req.RequestUri?.ToString(), excludedPatterns);
+                        o.FilterHttpRequestMessage = req => ShouldTraceHttpRequest(req, excludedPatterns);
+                        o.EnrichWithHttpRequestMessage = EnrichHttpClientActivity;
                     });
                 }
 
-                if (opts.Tracing.EnableEntityFrameworkCore)
+                if (opts.Tracing.EnableEntityFrameworkCore && AetherTracingRuntime.IsVerbose)
                 {
                     tracing.AddEntityFrameworkCoreInstrumentation();
                 }
 
                 tracing.AddSource("BBT.Aether.Aspects");
                 tracing.AddSource("BBT.Aether.Infrastructure");
+
+                if (!AetherTracingRuntime.IsVerbose)
+                {
+                    tracing.AddProcessor(new BusinessSpanFilterProcessor());
+                }
 
                 // Custom sources
                 foreach (var src in opts.Tracing.AdditionalSources)
@@ -233,7 +241,7 @@
                 if (!opts.LoggingEnabled) return;
 
                 logging.SetResourceBuilder(ResourceBuilder.CreateDefault()
                     .AddService(opts.ServiceName!, opts.ServiceNamespace ?? "aether", opts.ServiceVersion ?? "1.0.0", false, Environment.MachineName)
                     .AddAttributes(opts.Logging.Enrichers.CustomAttributes
                         .ToDictionary(x => x.Key, x => (object)x.Value)));
 
@@ -262,7 +270,7 @@
     }
 
     private static List<Regex> CompileRegex(IEnumerable<string> patterns)
         => patterns.Select(p => new Regex(p, RegexOptions.Compiled | RegexOptions.IgnoreCase)).ToList();
 
     private static bool IsExcluded(string? value, List<Regex> patterns)
     {
@@ -285,6 +293,67 @@
         return false;
     }
 
+    private static bool ShouldTraceHttpRequest(HttpRequestMessage request, List<Regex> excludedPatterns)
+    {
+        if (IsExcluded(request.RequestUri?.ToString(), excludedPatterns))
+        {
+            return false;
+        }
+
+        return AetherTracingRuntime.IsVerbose || !IsDaprDiagnosticRequest(request.RequestUri);
+    }
+
+    private static bool IsDaprDiagnosticRequest(Uri? uri)
+    {
+        var path = uri?.AbsolutePath;
+        if (string.IsNullOrEmpty(path))
+        {
+            return false;
+        }
+
+        if (path.StartsWith("/dapr.proto.runtime.v1.Dapr/", StringComparison.OrdinalIgnoreCase))
+        {
+            return path.EndsWith("/GetState", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/GetBulkState", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/SaveState", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/DeleteState", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/ExecuteStateTransaction", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/GetSecret", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/GetBulkSecret", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/GetConfiguration", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/SubscribeConfiguration", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/TryLockAlpha1", StringComparison.OrdinalIgnoreCase)
+                   || path.EndsWith("/UnlockAlpha1", StringComparison.OrdinalIgnoreCase);
+        }
+
+        return path.StartsWith("/v1.0/state/", StringComparison.OrdinalIgnoreCase)
+               || path.StartsWith("/v1.0-alpha1/state/", StringComparison.OrdinalIgnoreCase)
+               || path.StartsWith("/v1.0-alpha1/lock/", StringComparison.OrdinalIgnoreCase)
+               || path.StartsWith("/v1.0/secrets/", StringComparison.OrdinalIgnoreCase)
+               || path.StartsWith("/v1.0/configuration/", StringComparison.OrdinalIgnoreCase);
+    }
+
+    private static void EnrichHttpClientActivity(Activity activity, HttpRequestMessage request)
+    {
+        var segments = request.RequestUri?.AbsolutePath.Split('/', StringSplitOptions.RemoveEmptyEntries);
+        if (segments is not { Length: >= 5 }
+            || !string.Equals(segments[0], "v1.0", StringComparison.OrdinalIgnoreCase)
+            || !string.Equals(segments[1], "invoke", StringComparison.OrdinalIgnoreCase)
+            || !string.Equals(segments[3], "method", StringComparison.OrdinalIgnoreCase))
+        {
+            return;
+        }
+
+        var appId = Uri.UnescapeDataString(segments[2]);
+        var method = Uri.UnescapeDataString(string.Join('/', segments.Skip(4)));
+
+        activity.DisplayName = $"Dapr invoke {appId}";
+        activity.SetTag("rpc.system", "dapr");
+        activity.SetTag("rpc.service", appId);
+        activity.SetTag("rpc.method", method);
+        activity.SetTag("dapr.app_id", appId);
+    }
+
     private static string GetRoutePatternSafe(HttpContext httpContext)
     {
         try
@@ -302,4 +371,4 @@
     {
         return $"{environment}-{options.ServiceName}-{DateTime.UtcNow:yyyyMMdd-HHmmss}-{Guid.NewGuid().ToString("N")[..8]}";
     }
-}
+}

framework/src/BBT.Aether.Core/BBT/Aether/Telemetry/AetherTracingProfile.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Threading;
+
+namespace BBT.Aether.Telemetry;
+
+/// <summary>
+/// Controls the amount of tracing detail produced by Aether instrumentation.
+/// </summary>
+public enum AetherTracingDetailLevel
+{
+    /// <summary>
+    /// Keeps service boundaries and business spans while suppressing diagnostic detail.
+    /// </summary>
+    Business = 0,
+
+    /// <summary>
+    /// Keeps both business and diagnostic spans.
+    /// </summary>
+    Verbose = 1
+}
+
+/// <summary>
+/// Provides the process-wide tracing detail level used by static instrumentation and aspects.
+/// </summary>
+public static class AetherTracingRuntime
+{
+    private static int _detailLevel = (int)AetherTracingDetailLevel.Business;
+
+    /// <summary>
+    /// Gets the active tracing detail level.
+    /// </summary>
+    public static AetherTracingDetailLevel DetailLevel =>
+        (AetherTracingDetailLevel)Volatile.Read(ref _detailLevel);
+
+    /// <summary>
+    /// Gets whether diagnostic spans are enabled.
+    /// </summary>
+    public static bool IsVerbose => DetailLevel == AetherTracingDetailLevel.Verbose;
+
+    /// <summary>
+    /// Configures the process-wide tracing detail level.
+    /// </summary>
+    public static void Configure(AetherTracingDetailLevel detailLevel)
+    {
+        if (!Enum.IsDefined(detailLevel))
+        {
+            throw new ArgumentOutOfRangeException(nameof(detailLevel), detailLevel, "Unsupported tracing detail level.");
+        }
+
+        Volatile.Write(ref _detailLevel, (int)detailLevel);
+    }
+}

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedCache/Dapr/DaprDistributedCacheService.cs

@@ -89,7 +89,7 @@ public override Task RefreshAsync(string key, CancellationToken cancellationToke
 
     private Activity? StartCacheActivity(string operationName, string key)
     {
-        var activity = InfrastructureActivitySource.Source.StartActivity(
+        var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             operationName,
             ActivityKind.Client,
             Activity.Current?.Context ?? default);

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedCache/Redis/RedisDistributedCacheService.cs

@@ -33,14 +33,14 @@
 
             if (!cachedValue.HasValue)
             {
                 _logger.LogDebug("Cache miss for key: {Key}", key);
                 activity?.SetTag("cache.hit", false);
                 activity?.SetStatus(ActivityStatusCode.Ok);
                 return null;
             }
 
             var result = JsonSerializer.Deserialize<T>((string)cachedValue!, _jsonOptions);
             _logger.LogDebug("Cache hit for key: {Key}", key);
             activity?.SetTag("cache.hit", true);
             activity?.SetStatus(ActivityStatusCode.Ok);
             return result;
@@ -83,7 +83,7 @@
             }
 
             await database.StringSetAsync(key, serializedValue, expiry, keepTtl: false);
             _logger.LogDebug("Successfully cached value for key: {Key} with expiry: {Expiry}", key, expiry);
             activity?.SetStatus(ActivityStatusCode.Ok);
         }
         catch (Exception ex)
@@ -105,11 +105,11 @@
 
             if (removed)
             {
                 _logger.LogDebug("Successfully removed key from cache: {Key}", key);
             }
             else
             {
                 _logger.LogDebug("Key not found in cache: {Key}", key);
             }
 
             activity?.SetStatus(ActivityStatusCode.Ok);
@@ -134,11 +134,11 @@
             if (exists)
             {
                 await database.KeyTouchAsync(key);
                 _logger.LogDebug("Successfully refreshed key: {Key}", key);
             }
             else
             {
                 _logger.LogDebug("Key does not exist for refresh: {Key}", key);
             }
 
             activity?.SetStatus(ActivityStatusCode.Ok);
@@ -153,7 +153,7 @@
 
     private static Activity? StartCacheActivity(string operationName, string key)
     {
-        var activity = InfrastructureActivitySource.Source.StartActivity(
+        var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             operationName,
             ActivityKind.Client,
             Activity.Current?.Context ?? default);

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedLock/Dapr/DaprDistributedLockHandle.cs

@@ -58,7 +58,7 @@
         if (Interlocked.Exchange(ref _disposed, 1) == 1)
             return;
 
-        using var activity = InfrastructureActivitySource.Source.StartActivity(
+        using var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             "DistributedLock.Release",
             ActivityKind.Client,
             Activity.Current?.Context ?? default);
@@ -74,8 +74,8 @@
             activity?.SetTag("lock.released", true);
             activity?.SetStatus(ActivityStatusCode.Ok);
 
             logger.LogDebug("Released Dapr lock for resource {ResourceId} with owner {Owner}",
                 lockKey, owner);
         }
         catch (Exception ex)
         {

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedLock/Dapr/DaprDistributedLockService.cs

@@ -16,7 +16,7 @@
 public class DaprDistributedLockService(
     DaprClient daprClient,
     ILogger<DaprDistributedLockService> logger,
     IApplicationInfoAccessor applicationInfoAccessor,
     string storeName)
     : IDistributedLockService
 {
@@ -32,9 +32,9 @@
                 await daprClient.Lock(storeName, resourceId, lockOwner, expiryInSeconds, cancellationToken);
             if (resourceLock is { Success: true })
             {
                 logger.LogDebug("Successfully acquired lock for resource {ResourceId} with owner {Owner}",
                     resourceId, lockOwner);
                 activity?.SetTag("lock.acquired", true);
                 activity?.SetStatus(ActivityStatusCode.Ok);
                 return new DaprDistributedLockHandle(daprClient, storeName, resourceId, lockOwner, logger);
             }
@@ -52,10 +52,10 @@
         }
     }
 
     [Obsolete("Use IDistributedLockHandle.ReleaseAsync() or dispose the handle returned by TryAcquireLockAsync. This method uses a static owner and cannot reliably release locks acquired concurrently.")]
     public async Task<bool> ReleaseLockAsync(string resourceId, CancellationToken cancellationToken = default)
     {
-        using var activity = InfrastructureActivitySource.Source.StartActivity(
+        using var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             "DistributedLock.Release",
             ActivityKind.Client,
             Activity.Current?.Context ?? default);
@@ -98,13 +98,13 @@
                 return (false, default);
             }
 
             logger.LogDebug("Successfully acquired lock for resource {ResourceId}", resourceId);
             activity?.SetTag("lock.acquired", true);
             var result = await function();
             activity?.SetStatus(ActivityStatusCode.Ok);
             return (true, result);
         }
         catch (Exception ex)
         {
             logger.LogError(ex, "Error executing function with Dapr lock for resource {ResourceId}", resourceId);
             RecordException(activity, ex);
@@ -130,13 +130,13 @@
                 return false;
             }
 
             logger.LogDebug("Successfully acquired lock for resource {ResourceId}", resourceId);
             activity?.SetTag("lock.acquired", true);
             await action();
             activity?.SetStatus(ActivityStatusCode.Ok);
             return true;
         }
         catch (Exception ex)
         {
             logger.LogError(ex, "Error executing action with Dapr lock for resource {ResourceId}", resourceId);
             RecordException(activity, ex);
@@ -151,7 +151,7 @@
 
     private Activity? StartLockActivity(string operationName, string resourceId, int expiryInSeconds)
     {
-        var activity = InfrastructureActivitySource.Source.StartActivity(
+        var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             operationName,
             ActivityKind.Client,
             Activity.Current?.Context ?? default);

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedLock/Redis/RedisDistributedLockHandle.cs

@@ -46,7 +46,7 @@
         if (Volatile.Read(ref _disposed) == 1)
             return false;
 
-        using var activity = InfrastructureActivitySource.Source.StartActivity(
+        using var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             "DistributedLock.Extend",
             ActivityKind.Client,
             Activity.Current?.Context ?? default);
@@ -70,8 +70,8 @@
 
             if (extended)
             {
                 logger.LogDebug("Extended Redis lock TTL for resource {ResourceId} by {LeaseSeconds}s",
                     lockKey, leaseSeconds);
             }
             else
             {
@@ -96,7 +96,7 @@
         if (Interlocked.Exchange(ref _disposed, 1) == 1)
             return;
 
-        using var activity = InfrastructureActivitySource.Source.StartActivity(
+        using var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             "DistributedLock.Release",
             ActivityKind.Client,
             Activity.Current?.Context ?? default);
@@ -113,14 +113,14 @@
 
             if (result > 0)
             {
                 logger.LogDebug("Released Redis lock for resource {ResourceId} with owner {Owner}",
                     lockKey, owner);
                 activity?.SetTag("lock.released", true);
             }
             else
             {
                 logger.LogDebug("No Redis lock to release or owner mismatch for resource {ResourceId} with owner {Owner}",
                     lockKey, owner);
                 activity?.SetTag("lock.released", false);
             }
 

framework/src/BBT.Aether.Infrastructure/BBT/Aether/DistributedLock/Redis/RedisDistributedLockService.cs

@@ -14,7 +14,7 @@
 public class RedisDistributedLockService(
     IConnectionMultiplexer redisConnection,
     ILogger<RedisDistributedLockService> logger,
     IApplicationInfoAccessor applicationInfoAccessor)
     : IDistributedLockService
 {
     public async Task<IDistributedLockHandle?> TryAcquireLockAsync(string resourceId, int expiryInSeconds = 60,
@@ -37,9 +37,9 @@
 
             if (acquired)
             {
                 logger.LogDebug("Successfully acquired Redis lock for resource {ResourceId} with owner {LockOwner}",
                     resourceId, lockOwner);
                 activity?.SetTag("lock.acquired", true);
                 activity?.SetStatus(ActivityStatusCode.Ok);
                 return new RedisDistributedLockHandle(database, resourceId, lockOwner, logger);
             }
@@ -57,10 +57,10 @@
         }
     }
 
     [Obsolete("Use IDistributedLockHandle.ReleaseAsync() or dispose the handle returned by TryAcquireLockAsync. This method uses a static owner and cannot reliably release locks acquired concurrently.")]
     public async Task<bool> ReleaseLockAsync(string resourceId, CancellationToken cancellationToken = default)
     {
-        using var activity = InfrastructureActivitySource.Source.StartActivity(
+        using var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             "DistributedLock.Release",
             ActivityKind.Client,
             Activity.Current?.Context ?? default);
@@ -89,8 +89,8 @@
 
             if (released)
             {
                 logger.LogDebug("Successfully released Redis lock for resource {ResourceId} with owner {LockOwner}",
                     resourceId, lockOwner);
             }
             else
             {
@@ -190,7 +190,7 @@
 
     private static Activity? StartLockActivity(string operationName, string resourceId, int expiryInSeconds)
     {
-        var activity = InfrastructureActivitySource.Source.StartActivity(
+        var activity = InfrastructureActivitySource.StartDiagnosticActivity(
             operationName,
             ActivityKind.Client,
             Activity.Current?.Context ?? default);

framework/src/BBT.Aether.Infrastructure/BBT/Aether/Telemetry/InfrastructureActivitySource.cs

@@ -22,4 +22,17 @@ public static class InfrastructureActivitySource
     /// The shared ActivitySource instance for creating activities (spans) in Aether infrastructure.
     /// </summary>
     public static readonly ActivitySource Source = new(SourceName, Version);
+
+    /// <summary>
+    /// Starts an infrastructure diagnostic span only when the global tracing profile is Verbose.
+    /// </summary>
+    public static Activity? StartDiagnosticActivity(
+        string operationName,
+        ActivityKind kind,
+        ActivityContext parentContext = default)
+    {
+        return AetherTracingRuntime.IsVerbose
+            ? Source.StartActivity(operationName, kind, parentContext)
+            : null;
+    }
 }