Skip to content

Commit 94aa39c

Browse files
committed
feat(telemetry): add requestId support for better error tracking 🔍
1 parent 231ed17 commit 94aa39c

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

mcp/src/utils/telemetry.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,7 @@ export const telemetryReporter = new TelemetryReporter();
235235
export const reportToolCall = async (params: {
236236
toolName: string;
237237
success: boolean;
238+
requestId?: string;
238239
duration?: number;
239240
error?: string;
240241
inputParams?: any; // 入参上报
@@ -267,6 +268,7 @@ export const reportToolCall = async (params: {
267268
const eventData: { [key: string]: any } = {
268269
toolName: params.toolName,
269270
success: params.success ? 'true' : 'false',
271+
requestId: params.requestId,
270272
duration: params.duration,
271273
error: params.error ? params.error.substring(0, 200) : undefined ,// 限制错误信息长度
272274
envId: envId || 'unknown',

mcp/src/utils/tool-wrapper.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@ function createWrappedHandler(name: string, handler: any, server: ExtendedMcpSer
107107
const startTime = Date.now();
108108
let success = false;
109109
let errorMessage: string | undefined;
110+
let requestId: string | undefined;
110111

111112
try {
112113
debug(`开始执行工具: ${name}`, { args: sanitizeArgs(args) });
@@ -121,7 +122,7 @@ function createWrappedHandler(name: string, handler: any, server: ExtendedMcpSer
121122
} catch (error) {
122123
success = false;
123124
errorMessage = error instanceof Error ? error.message : String(error);
124-
125+
requestId = (typeof error === 'object' && error && 'requestId' in error) ? (error as any).requestId : '';
125126
debug(`工具执行失败: ${name}`, {
126127
error: errorMessage,
127128
duration: Date.now() - startTime
@@ -153,6 +154,7 @@ function createWrappedHandler(name: string, handler: any, server: ExtendedMcpSer
153154
reportToolCall({
154155
toolName: name,
155156
success,
157+
156158
duration,
157159
error: errorMessage,
158160
inputParams: sanitizeArgs(args), // 添加入参上报

0 commit comments

Comments
 (0)