Skip to content

Add handling of stable database client span semantic conventions #53050

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rajkumar-rangaraj merged 7 commits into from
Oct 8, 2025
Merged

Add handling of stable database client span semantic conventions #53050

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
6a77f8d
initial changes
Oct 7, 2025
16419d7
initial go at tests
Oct 7, 2025
0ba86db
fix test
Oct 7, 2025
26b9160
add tags tests
Oct 7, 2025
d4b7d7b
fix tests
Oct 7, 2025
f3c3c36
update changelog
Oct 7, 2025
5814105
PR feedback
Oct 7, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
initial changes
  • Loading branch information
Matthew Sainsbury committed Oct 7, 2025
commit 6a77f8de1575bf5f68e4555a1f93ecb41af0d43c
20 changes: 16 additions & 4 deletions ...or/Azure.Monitor.OpenTelemetry.Exporter/src/Customizations/Models/RemoteDependencyData.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ public RemoteDependencyData(int version, Activity activity, ref ActivityTagsProc
SetHttpDependencyPropertiesAndDependencyName(activity, ref activityTagsProcessor.MappedTags, isNewSchemaVersion, out dependencyName);
break;
case OperationType.Db:
SetDbDependencyProperties(ref activityTagsProcessor.MappedTags);
SetDbDependencyProperties(ref activityTagsProcessor.MappedTags, isNewSchemaVersion);
break;
case OperationType.Messaging:
SetMessagingDependencyProperties(activity, ref activityTagsProcessor.MappedTags);
Expand Down Expand Up @@ -86,11 +86,23 @@ private void SetHttpDependencyPropertiesAndDependencyName(Activity activity, ref
ResultCode = resultCode?.Truncate(SchemaConstants.RemoteDependencyData_ResultCode_MaxLength) ?? "0";
}

private void SetDbDependencyProperties(ref AzMonList dbTagObjects)
private void SetDbDependencyProperties(ref AzMonList dbTagObjects, bool isNewSchemaVersion)
{
var dbAttributeTagObjects = AzMonList.GetTagValues(ref dbTagObjects, SemanticConventions.AttributeDbStatement, SemanticConventions.AttributeDbSystem);
string statementAttributeKey;
string statementSystemKey;
if (isNewSchemaVersion)
{
statementAttributeKey = SemanticConventions.AttributeDbQueryText;
statementSystemKey = SemanticConventions.AttributeDbSystemName;
}
else
{
statementAttributeKey = SemanticConventions.AttributeDbStatement;
statementSystemKey = SemanticConventions.AttributeDbSystem;
}
var dbAttributeTagObjects = AzMonList.GetTagValues(ref dbTagObjects, statementAttributeKey, statementSystemKey);
Data = dbAttributeTagObjects[0]?.ToString().Truncate(SchemaConstants.RemoteDependencyData_Data_MaxLength);
var (DbName, DbTarget) = dbTagObjects.GetDbDependencyTargetAndName();
var (DbName, DbTarget) = dbTagObjects.GetDbDependencyTargetAndName(isNewSchemaVersion);
Target = DbTarget?.Truncate(SchemaConstants.RemoteDependencyData_Target_MaxLength);
Type = AzMonListExtensions.s_dbSystems.Contains(dbAttributeTagObjects[1]?.ToString()) ? "SQL" : dbAttributeTagObjects[1]?.ToString().Truncate(SchemaConstants.RemoteDependencyData_Type_MaxLength);

Expand Down
3 changes: 3 additions & 0 deletions sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Internals/ActivityTagsProcessor.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,9 @@ public void CategorizeTags(Activity activity)
case SemanticConventions.AttributeDbSystem:
activityType = OperationType.Db;
break;
case SemanticConventions.AttributeDbSystemName:
activityType = OperationType.Db | OperationType.V2;
break;
case SemanticConventions.AttributeMessagingSystem:
activityType = OperationType.Messaging;
break;
Expand Down
19 changes: 15 additions & 4 deletions sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Internals/AzMonListExtensions.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -329,9 +329,20 @@ internal static string GetDefaultDbPort(string? dbSystem)
///<summary>
/// Gets Database dependency target and name from activity tag objects.
///</summary>
internal static (string? DbName, string? DbTarget) GetDbDependencyTargetAndName(this AzMonList tagObjects)
internal static (string? DbName, string? DbTarget) GetDbDependencyTargetAndName(this AzMonList tagObjects, bool isNewSchemaVersion)
{
var peerServiceAndDbSystem = AzMonList.GetTagValues(ref tagObjects, SemanticConventions.AttributePeerService, SemanticConventions.AttributeDbSystem);

string statementDbNameKey;
string statementDbSystemKey;
if (isNewSchemaVersion) {
statementDbNameKey = SemanticConventions.AttributeDbNamespace;
statementDbSystemKey = SemanticConventions.AttributeDbSystemName;
} else {
statementDbNameKey = SemanticConventions.AttributeDbName;
statementDbSystemKey = SemanticConventions.AttributeDbSystem;
}

var peerServiceAndDbSystem = AzMonList.GetTagValues(ref tagObjects, SemanticConventions.AttributePeerService, statementDbSystemKey);
string? target = peerServiceAndDbSystem[0]?.ToString();
var defaultPort = GetDefaultDbPort(peerServiceAndDbSystem[1]?.ToString());

Expand All @@ -340,7 +351,7 @@ internal static (string? DbName, string? DbTarget) GetDbDependencyTargetAndName(
target = tagObjects.GetTargetUsingServerAttributes(defaultPort) ?? tagObjects.GetTargetUsingNetPeerAttributes(defaultPort);
}

var dbName = AzMonList.GetTagValue(ref tagObjects, SemanticConventions.AttributeDbName)?.ToString();
var dbName = AzMonList.GetTagValue(ref tagObjects, statementDbNameKey)?.ToString();
bool isTargetEmpty = string.IsNullOrWhiteSpace(target);
bool isDbNameEmpty = string.IsNullOrWhiteSpace(dbName);
if (!isTargetEmpty && !isDbNameEmpty)
Expand All @@ -353,7 +364,7 @@ internal static (string? DbName, string? DbTarget) GetDbDependencyTargetAndName(
}
else if (isTargetEmpty && isDbNameEmpty)
{
target = AzMonList.GetTagValue(ref tagObjects, SemanticConventions.AttributeDbSystem)?.ToString();
target = AzMonList.GetTagValue(ref tagObjects, statementDbSystemKey)?.ToString();
}

return (DbName: dbName, DbTarget: target);
Expand Down
11 changes: 11 additions & 0 deletions sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Internals/SemanticConventions.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -164,5 +164,16 @@ internal static class SemanticConventions
// Messaging v1.21.0 https://github.com/open-telemetry/opentelemetry-specification/blob/v1.21.0/specification/trace/semantic_conventions/messaging.md
public const string AttributeMessagingDestinationName = "messaging.destination.name";
public const string AttributeNetworkProtocolName = "network.protocol.name";

// Database v1.36.0 https://github.com/open-telemetry/semantic-conventions/tree/v1.36.0/docs/database
public const string AttributeDbCollectionName = "db.collection.name";
public const string AttributeDbOperationName = "db.operation.name";
public const string AttributeDbSystemName = "db.system.name";
public const string AttributeDbNamespace = "db.namespace";
public const string AttributeDbResponseStatusCode = "db.response.status_code";
public const string AttributeDbOperationBatchSize = "db.operation.batch.size";
public const string AttributeDbQuerySummary = "db.query.summary";
public const string AttributeDbQueryText = "db.query.text";
public const string AttributeDbStoredProcedureName = "db.stored_procedure.name";
}
}