Support new telemetry schema attribute names

CHANGELOG.md

@@ -7,6 +7,31 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Breaking Changes - A365 Observability Schema Migration
+
+**Telemetry attribute names have been updated to align with the official A365 Observability Schema:**
+
+#### Human Caller Attributes (Now OTel Standard)
+- `GEN_AI_CALLER_ID_KEY` → `USER_ID_KEY` (`user.id`)
+- `GEN_AI_CALLER_NAME_KEY` → `USER_NAME_KEY` (`user.name`)
+- `GEN_AI_CALLER_UPN_KEY` → `USER_EMAIL_KEY` (`user.email`)
+- `GEN_AI_CALLER_CLIENT_IP_KEY` → `CLIENT_ADDRESS_KEY` (`client.address`)
+
+#### Agent Identity Attributes
+- `GEN_AI_AGENT_AUID_KEY` → `AGENT_USER_ID_KEY` (`microsoft.agent.user.id`)
+- `GEN_AI_AGENT_UPN_KEY` → `AGENT_EMAIL_KEY` (`microsoft.agent.user.email`)
+- `GEN_AI_AGENT_BLUEPRINT_ID_KEY` → `AGENT_BLUEPRINT_ID_KEY` (`microsoft.a365.agent.blueprint.id`)
+
+#### Agent-to-Agent Caller Attributes
+- `GEN_AI_CALLER_AGENT_USER_ID_KEY` → `CALLER_AGENT_USER_ID_KEY` (`microsoft.a365.caller.agent.user.id`)
+- `GEN_AI_CALLER_AGENT_UPN_KEY` → `CALLER_AGENT_EMAIL_KEY` (`microsoft.a365.caller.agent.user.email`)
+- `GEN_AI_CALLER_AGENT_NAME_KEY` → `CALLER_AGENT_NAME_KEY` (`microsoft.a365.caller.agent.name`)
+- `GEN_AI_CALLER_AGENT_ID_KEY` → `CALLER_AGENT_ID_KEY` (`microsoft.a365.caller.agent.id`)
+- `GEN_AI_CALLER_AGENT_APPLICATION_ID_KEY` → `CALLER_AGENT_BLUEPRINT_ID_KEY` (`microsoft.a365.caller.agent.blueprint.id`)
+- `GEN_AI_CALLER_AGENT_PLATFORM_ID_KEY` → `CALLER_AGENT_PLATFORM_ID_KEY` (`microsoft.a365.caller.agent.platform.id`)
+
+**Migration Impact:** All code using the old constant names must be updated to use the new names. The attribute values now follow OTel semantic conventions for human callers (`user.*`) and Microsoft-specific namespaces for agent attributes (`microsoft.*`).
+
 ### Added
 
 - **`OpenAIAgentsInstrumentationConfig.isContentRecordingEnabled`** — Optional `boolean` to enable content recording in OpenAI trace processor.

packages/agents-a365-observability-extensions-langchain/src/tracer.ts

@@ -72,7 +72,7 @@ export class LangChainTracer extends BaseTracer {
     const span = this.tracer.startSpan(spanName, {
       kind: SpanKind.INTERNAL,
       startTime,
-      attributes: { [OpenTelemetryConstants.GEN_AI_SYSTEM_KEY]: "langchain" },
+      attributes: { [OpenTelemetryConstants.GEN_AI_PROVIDER_NAME_KEY]: "langchain" },
     }, activeContext);
 
     this.runs.set(run.id, { run, span, startTime, lastAccessTime: startTime });

packages/agents-a365-observability-extensions-openai/src/OpenAIAgentsTraceProcessor.ts

@@ -42,9 +42,9 @@ export class OpenAIAgentsTraceProcessor implements TracingProcessor {
   private readonly spanNames: Map<OtelSpan, string> = new Map();
 
   private readonly keyMappings: Map<string, string> = new Map([
-    ['mcp_tools' + Constants.GEN_AI_RESPONSE_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_EVENT_CONTENT],
+    ['mcp_tools' + Constants.GEN_AI_RESPONSE_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_TOOL_CALL_RESULT_KEY],
     ['mcp_tools' + Constants.GEN_AI_REQUEST_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_TOOL_ARGS_KEY],
-    ['function' + Constants.GEN_AI_RESPONSE_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_EVENT_CONTENT],
+    ['function' + Constants.GEN_AI_RESPONSE_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_TOOL_CALL_RESULT_KEY],
     ['function' + Constants.GEN_AI_REQUEST_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_TOOL_ARGS_KEY],
     ['generation' + Constants.GEN_AI_RESPONSE_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_OUTPUT_MESSAGES_KEY],
     ['generation' + Constants.GEN_AI_REQUEST_CONTENT_KEY, OpenTelemetryConstants.GEN_AI_INPUT_MESSAGES_KEY],
@@ -59,8 +59,8 @@ export class OpenAIAgentsTraceProcessor implements TracingProcessor {
   private static readonly CONTENT_KEYS = new Set([
     OpenTelemetryConstants.GEN_AI_INPUT_MESSAGES_KEY,
     OpenTelemetryConstants.GEN_AI_OUTPUT_MESSAGES_KEY,
-    OpenTelemetryConstants.GEN_AI_EVENT_CONTENT,
     OpenTelemetryConstants.GEN_AI_TOOL_ARGS_KEY,
+    OpenTelemetryConstants.GEN_AI_TOOL_CALL_RESULT_KEY,
     Constants.GEN_AI_REQUEST_CONTENT_KEY,
     Constants.GEN_AI_RESPONSE_CONTENT_KEY,
   ]);
@@ -138,7 +138,7 @@ export class OpenAIAgentsTraceProcessor implements TracingProcessor {
         startTime,
         attributes: {
           [OpenTelemetryConstants.GEN_AI_OPERATION_NAME_KEY]: Utils.getSpanKind(spanData),
-          [OpenTelemetryConstants.GEN_AI_SYSTEM_KEY]: 'openai',
+          [OpenTelemetryConstants.GEN_AI_PROVIDER_NAME_KEY]: 'openai',
         },
       },
       parentContext

packages/agents-a365-observability-extensions-openai/src/Utils.ts

@@ -94,10 +94,6 @@ export function getAttributesFromGenerationSpanData(data: SpanData): Record<stri
 
   if (genData.output) {
     attributes[Constants.GEN_AI_RESPONSE_CONTENT_KEY] = safeJsonDumps(genData.output);
-    const output = genData.output as Record<string, unknown>;
-    if (output.id) {
-      attributes[OpenTelemetryConstants.GEN_AI_RESPONSE_ID_KEY] = output.id;
-    }
   }
 
   if (genData.usage) {

packages/agents-a365-observability-hosting/src/middleware/OutputLoggingMiddleware.ts

@@ -109,7 +109,6 @@ export class OutputLoggingMiddleware implements Middleware {
         callerDetails,
         conversationId,
         sourceMetadata,
-        undefined,
         parentSpanRef,
       );
       try {

packages/agents-a365-observability-hosting/src/utils/ScopeUtils.ts

@@ -261,7 +261,7 @@ export class ScopeUtils {
     if (!tenant) {
       throw new Error('populateExecuteToolScopeFromTurnContext: Missing tenant details on TurnContext (recipient)');
     }
-    const scope = ExecuteToolScope.start(details, agent, tenant, conversationId, sourceMetadata, undefined, startTime, endTime, spanKind);
+    const scope = ExecuteToolScope.start(details, agent, tenant, conversationId, sourceMetadata, undefined, startTime, endTime, undefined, spanKind);
     return scope;
   }
 

packages/agents-a365-observability-hosting/src/utils/TurnContextUtils.ts

@@ -21,7 +21,7 @@ function normalizePairs(pairs: Array<[string, string | undefined]>): Array<[stri
 /**
  * Extracts caller-related OpenTelemetry baggage pairs from the TurnContext.
  * @param turnContext The current TurnContext (activity context)
- * @returns Array of [key, value] pairs for caller identity and tenant
+ * @returns Array of [key, value] pairs for caller identity
  */
 export function getCallerBaggagePairs(turnContext: TurnContext): Array<[string, string]> {
   if (!turnContext|| !turnContext.activity?.from) { 
@@ -31,11 +31,10 @@ export function getCallerBaggagePairs(turnContext: TurnContext): Array<[string,
 
   const upn = from.agenticUserId;
   const pairs: Array<[string, string | undefined]> = [
-    [OpenTelemetryConstants.GEN_AI_CALLER_ID_KEY, from.aadObjectId],
-    [OpenTelemetryConstants.GEN_AI_CALLER_NAME_KEY, from.name],
-    [OpenTelemetryConstants.GEN_AI_CALLER_UPN_KEY, upn],
-    [OpenTelemetryConstants.GEN_AI_CALLER_TENANT_ID_KEY, from.tenantId],
-    [OpenTelemetryConstants.GEN_AI_AGENT_BLUEPRINT_ID_KEY, from.agenticAppBlueprintId]
+    [OpenTelemetryConstants.USER_ID_KEY, from.aadObjectId],
+    [OpenTelemetryConstants.USER_NAME_KEY, from.name],
+    [OpenTelemetryConstants.USER_EMAIL_KEY, upn],
+    [OpenTelemetryConstants.CALLER_AGENT_BLUEPRINT_ID_KEY, from.agenticAppBlueprintId]
   ];
   return normalizePairs(pairs);
 }
@@ -103,7 +102,7 @@ export function getTargetAgentBaggagePairs(turnContext: TurnContext, authToken?:
     [OpenTelemetryConstants.GEN_AI_AGENT_ID_KEY, agentId],
     [OpenTelemetryConstants.GEN_AI_AGENT_NAME_KEY, agentName],
     [OpenTelemetryConstants.GEN_AI_AGENT_DESCRIPTION_KEY, agentDescription],
-    [OpenTelemetryConstants.GEN_AI_AGENT_AUID_KEY, aadObjectId],
+    [OpenTelemetryConstants.AGENT_USER_ID_KEY, aadObjectId],
   ];
   return normalizePairs(pairs);
 }
@@ -128,8 +127,8 @@ export function getSourceMetadataBaggagePairs(turnContext: TurnContext): Array<[
     return [];
   }  
   const pairs: Array<[string, string | undefined]> = [
-    [OpenTelemetryConstants.GEN_AI_EXECUTION_SOURCE_NAME_KEY, turnContext.activity?.channelId],
-    [OpenTelemetryConstants.GEN_AI_EXECUTION_SOURCE_DESCRIPTION_KEY, turnContext.activity?.channelIdSubChannel as string | undefined]
+    [OpenTelemetryConstants.CHANNEL_NAME_KEY, turnContext.activity?.channelId],
+    [OpenTelemetryConstants.CHANNEL_LINK_KEY, turnContext.activity?.channelIdSubChannel as string | undefined]
   ];
   return normalizePairs(pairs);
 }

packages/agents-a365-observability/.gitignore

@@ -0,0 +1,2 @@
+# The file "src/version.ts" is generated by a prebuild script and should not be committed.
+src/version.ts

packages/agents-a365-observability/package.json

@@ -6,6 +6,7 @@
   "module": "dist/esm/index.js",
   "types": "dist/esm/index.d.ts",
   "scripts": {
+    "prebuild": "node -p \"'export const LIB_VERSION = ' + JSON.stringify(require('./package.json').version) + ';'\" > src/version.ts",
     "build:cjs": "npx tsc --project tsconfig.cjs.json",
     "build:esm": "npx tsc --project tsconfig.esm.json",
     "build": "npm run build:cjs && npm run build:esm",

packages/agents-a365-observability/src/tracing/constants.ts

@@ -1,6 +1,7 @@
-// ------------------------------------------------------------------------------
-// Copyright (c) Microsoft Corporation. All rights reserved.
-// ------------------------------------------------------------------------------
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+import { LIB_VERSION } from '../version';
 
 /**
  * OpenTelemetry constants for Agent 365
@@ -36,19 +37,15 @@ export class OpenTelemetryConstants {
   public static readonly GEN_AI_REQUEST_MODEL_KEY = 'gen_ai.request.model';
   public static readonly GEN_AI_REQUEST_TEMPERATURE_KEY = 'gen_ai.request.temperature';
   public static readonly GEN_AI_REQUEST_TOP_P_KEY = 'gen_ai.request.top_p';
-  public static readonly GEN_AI_RESPONSE_ID_KEY = 'gen_ai.response.id';
   public static readonly GEN_AI_RESPONSE_FINISH_REASONS_KEY = 'gen_ai.response.finish_reasons';
   public static readonly GEN_AI_RESPONSE_MODEL_KEY = 'gen_ai.response.model';
-  public static readonly GEN_AI_SYSTEM_KEY = 'gen_ai.system';
-  public static readonly GEN_AI_SYSTEM_VALUE = 'az.ai.agent365';
-
   public static readonly GEN_AI_AGENT_ID_KEY = 'gen_ai.agent.id';
   public static readonly GEN_AI_AGENT_NAME_KEY = 'gen_ai.agent.name';
-  public static readonly GEN_AI_AGENT_TYPE_KEY = 'gen_ai.agent.type';
   public static readonly GEN_AI_AGENT_DESCRIPTION_KEY = 'gen_ai.agent.description';
-  public static readonly GEN_AI_AGENT_PLATFORM_ID_KEY = 'gen_ai.agent.platformid';
+  public static readonly GEN_AI_AGENT_PLATFORM_ID_KEY = 'microsoft.a365.agent.platform.id';
+  public static readonly GEN_AI_AGENT_THOUGHT_PROCESS_KEY = 'microsoft.a365.agent.thought.process';
   public static readonly GEN_AI_CONVERSATION_ID_KEY = 'gen_ai.conversation.id';
-  public static readonly GEN_AI_CONVERSATION_ITEM_LINK_KEY = 'gen_ai.conversation.item.link';
+  public static readonly GEN_AI_CONVERSATION_ITEM_LINK_KEY = 'microsoft.conversation.item.link';
   public static readonly GEN_AI_TOKEN_TYPE_KEY = 'gen_ai.token.type';
   public static readonly GEN_AI_USAGE_INPUT_TOKENS_KEY = 'gen_ai.usage.input_tokens';
   public static readonly GEN_AI_USAGE_OUTPUT_TOKENS_KEY = 'gen_ai.usage.output_tokens';
@@ -58,80 +55,60 @@ export class OpenTelemetryConstants {
   public static readonly GEN_AI_SYSTEM_INSTRUCTIONS_KEY = 'gen_ai.system_instructions';
   public static readonly GEN_AI_INPUT_MESSAGES_KEY = 'gen_ai.input.messages';
   public static readonly GEN_AI_OUTPUT_MESSAGES_KEY = 'gen_ai.output.messages';
-  public static readonly GEN_AI_EVENT_CONTENT = 'gen_ai.event.content';
-
   // Tool execution constants
   public static readonly GEN_AI_TOOL_CALL_ID_KEY = 'gen_ai.tool.call.id';
   public static readonly GEN_AI_TOOL_NAME_KEY = 'gen_ai.tool.name';
   public static readonly GEN_AI_TOOL_DESCRIPTION_KEY = 'gen_ai.tool.description';
   public static readonly GEN_AI_TOOL_ARGS_KEY = 'gen_ai.tool.call.arguments';
-  public static readonly GEN_AI_TOOL_CALL_RESULT_KEY = 'gen_ai.event.content'; // GEN_AI_EVENT_CONTENT
+  public static readonly GEN_AI_TOOL_CALL_RESULT_KEY = 'gen_ai.tool.call.result';
   public static readonly GEN_AI_TOOL_TYPE_KEY = 'gen_ai.tool.type';
 
-  // Agent user (user tied to agent instance during creation) or caller dimensions
-  public static readonly GEN_AI_AGENT_USER_ID_KEY = 'gen_ai.agent.userid';
-  public static readonly GEN_AI_CALLER_TENANT_ID_KEY = 'gen_ai.caller.tenantid';
-  public static readonly GEN_AI_CALLER_ID_KEY = 'gen_ai.caller.id';
-  public static readonly GEN_AI_CALLER_NAME_KEY = 'gen_ai.caller.name';
-  public static readonly GEN_AI_CALLER_UPN_KEY = 'gen_ai.caller.upn';
-  public static readonly GEN_AI_CALLER_CLIENT_IP_KEY = 'gen_ai.caller.client.ip';
+  // Human caller dimensions (OTel standard)
+  public static readonly USER_ID_KEY = 'user.id';
+  public static readonly USER_NAME_KEY = 'user.name';
+  public static readonly USER_EMAIL_KEY = 'user.email';
+  public static readonly CLIENT_ADDRESS_KEY = 'client.address';
 
   // Agent to Agent caller agent dimensions
-  public static readonly GEN_AI_CALLER_AGENT_USER_ID_KEY = 'gen_ai.caller.agent.userid';
-  public static readonly GEN_AI_CALLER_AGENT_UPN_KEY = 'gen_ai.caller.agent.upn';
-  public static readonly GEN_AI_CALLER_AGENT_TENANT_ID_KEY = 'gen_ai.caller.agent.tenantid';
-  public static readonly GEN_AI_CALLER_AGENT_NAME_KEY = 'gen_ai.caller.agent.name';
-  public static readonly GEN_AI_CALLER_AGENT_ID_KEY = 'gen_ai.caller.agent.id';
-  public static readonly GEN_AI_CALLER_AGENT_TYPE_KEY = 'gen_ai.caller.agent.type';
-  public static readonly GEN_AI_CALLER_AGENT_APPLICATION_ID_KEY = 'gen_ai.caller.agent.applicationid';
-  public static readonly GEN_AI_CALLER_AGENT_CLIENT_IP_KEY = 'gen_ai.caller.agent.user.client.ip';
-  public static readonly GEN_AI_CALLER_AGENT_PLATFORM_ID_KEY = 'gen_ai.caller.agent.platformid';
+  public static readonly CALLER_AGENT_USER_ID_KEY = 'microsoft.a365.caller.agent.user.id';
+  public static readonly CALLER_AGENT_EMAIL_KEY = 'microsoft.a365.caller.agent.user.email';
+  public static readonly CALLER_AGENT_NAME_KEY = 'microsoft.a365.caller.agent.name';
+  public static readonly CALLER_AGENT_ID_KEY = 'microsoft.a365.caller.agent.id';
+  public static readonly CALLER_AGENT_BLUEPRINT_ID_KEY = 'microsoft.a365.caller.agent.blueprint.id';
+  public static readonly CALLER_AGENT_PLATFORM_ID_KEY = 'microsoft.a365.caller.agent.platform.id';
   // Agent-specific dimensions
   public static readonly AGENT_ID_KEY = 'gen_ai.agent.id';
   public static readonly GEN_AI_TASK_ID_KEY = 'gen_ai.task.id';
-  public static readonly SESSION_ID_KEY = 'session.id';
-  public static readonly SESSION_DESCRIPTION_KEY = 'session.description';
+  public static readonly SESSION_ID_KEY = 'microsoft.session.id';
+  public static readonly SESSION_DESCRIPTION_KEY = 'microsoft.session.description';
   public static readonly GEN_AI_ICON_URI_KEY = 'gen_ai.agent365.icon_uri';
-  public static readonly TENANT_ID_KEY = 'tenant.id';
+  public static readonly TENANT_ID_KEY = 'microsoft.tenant.id';
 
-  // Baggage keys
-  public static readonly OPERATION_SOURCE_KEY = 'operation.source';
-  public static readonly GEN_AI_AGENT_AUID_KEY = 'gen_ai.agent.user.id';
-  public static readonly GEN_AI_AGENT_UPN_KEY = 'gen_ai.agent.upn';
-  public static readonly GEN_AI_AGENT_BLUEPRINT_ID_KEY = 'gen_ai.agent.applicationid';
-  public static readonly CORRELATION_ID_KEY = 'correlation.id';
-  public static readonly HIRING_MANAGER_ID_KEY = 'hiring.manager.id';
+  // Agent identity attributes
+  public static readonly AGENT_USER_ID_KEY = 'microsoft.agent.user.id';
+  public static readonly AGENT_EMAIL_KEY = 'microsoft.agent.user.email';
+  public static readonly AGENT_BLUEPRINT_ID_KEY = 'microsoft.a365.agent.blueprint.id';
 
   // Execution context dimensions
   public static readonly GEN_AI_EXECUTION_TYPE_KEY = 'gen_ai.execution.type';
   public static readonly GEN_AI_EXECUTION_PAYLOAD_KEY = 'gen_ai.execution.payload';
 
-  // Source metadata dimensions
-  public static readonly GEN_AI_EXECUTION_SOURCE_ID_KEY = 'gen_ai.execution.sourceMetadata.id';
-  public static readonly GEN_AI_EXECUTION_SOURCE_NAME_KEY = 'gen_ai.channel.name';
-  public static readonly GEN_AI_EXECUTION_SOURCE_DESCRIPTION_KEY = 'gen_ai.channel.link';
+  // Channel dimensions
+  public static readonly CHANNEL_NAME_KEY = 'microsoft.channel.name';
+  public static readonly CHANNEL_LINK_KEY = 'microsoft.channel.link';
 
   // Custom parent id and parent name key
   public static readonly CUSTOM_PARENT_SPAN_ID_KEY = 'custom.parent.span.id';
   public static readonly CUSTOM_SPAN_NAME_KEY = 'custom.span.name';
-}
-
-/**
- * Enumeration representing the source of an operation.
- */
-export enum OperationSource {
-  /**
-   * Operation executed by SDK.
-   */
-  SDK = 'SDK',
 
-  /**
-   * Operation executed by Gateway.
-   */
-  GATEWAY = 'Gateway',
+  // Service attributes
+  public static readonly SERVICE_NAME_KEY = 'service.name';
 
-  /**
-   * Operation executed by MCP Server.
-   */
-  MCP_SERVER = 'MCPServer',
+  // Telemetry SDK attributes
+  public static readonly TELEMETRY_SDK_NAME_KEY = 'telemetry.sdk.name';
+  public static readonly TELEMETRY_SDK_LANGUAGE_KEY = 'telemetry.sdk.language';
+  public static readonly TELEMETRY_SDK_VERSION_KEY = 'telemetry.sdk.version';
+  public static readonly TELEMETRY_SDK_NAME_VALUE = 'A365ObservabilitySDK';
+  public static readonly TELEMETRY_SDK_LANGUAGE_VALUE = 'nodejs';
+  public static readonly TELEMETRY_SDK_VERSION_VALUE = LIB_VERSION;
 }

packages/agents-a365-observability/src/tracing/contracts.ts

@@ -105,9 +105,6 @@ export interface AgentDetails {
   /** The human-readable name of the AI agent */
   agentName?: string;
 
-  /** Optional type of the AI agent */
-  agentType?: string;
-
   /** A description of the AI agent's purpose or capabilities */
   agentDescription?: string;
 
@@ -129,8 +126,8 @@ export interface AgentDetails {
   /** The tenant ID for the agent */
   tenantId?: string;
 
-  /** The client IP address for the agent user */
-  agentClientIP?: string;
+  /** The provider name (e.g., az.ai.agent365, openai, anthropic) */
+  providerName?: string;
 }
 
 /**
@@ -235,8 +232,11 @@ export interface InferenceDetails {
   /** Array of finish reasons */
   finishReasons?: string[];
 
-  /** Response ID from the model provider */
-  responseId?: string;
+  /** The thought process used by the agent */
+  thoughtProcess?: string;
+
+  /** The endpoint for the inference call */
+  endpoint?: ServiceEndpoint;
 }
 
 /**