feat: 测试post 请求 在trace中的展示

Author: guguji5

README.md

@@ -46,4 +46,13 @@ curl 'http://localhost:7001/api/users' \
   -H 'sec-ch-ua-platform: "macOS"'
 ```
 
-上访traceparent为RUM生成，在Flashcat的链路检索中，可以查询 **000000000000000032b049cf4aab3e2d** 即可查询处理
+上访traceparent为RUM生成，在Flashcat的链路检索中，可以查询 **000000000000000032b049cf4aab3e2d** 即可查询处理
+
+
+## 6.30 问题排查
+
+问：Post请求在Trace中无体现
+
+我在本demo中做了一个post接口测试了一下，可以展示
+
+**视频地址：https://c9xudyniiq.feishu.cn/file/PYIHbJPEDoptA4xcEirczcNcnSg**

app/controller/user.ts

@@ -2,7 +2,7 @@ import { Controller } from 'egg';
 import opentelemetry,{Span} from '@opentelemetry/api';
 import { mysqlQuery } from '../service/mysql';
 import { createMongoClient } from '../service/mongo';
-import request from '../service/request';
+// import request from '../service/request';
 const tracer = opentelemetry.trace.getTracer(
   'guguji9',
   '1.0.0',
@@ -56,12 +56,85 @@ export default class UserController extends Controller {
       parseInt(page as string), 
       parseInt(pageSize as string)
     );
-    const res2 = await request({uri:'http://10.99.1.223:8081/roll',method:'GET'})
+    // const res2 = await request({uri:'http://10.99.1.223:8081/roll',method:'GET'})
 
     ctx.body = {
       code: 0,
-      data: {result, res, res2, mongoRes},
+      data: {result, res, mongoRes},
+      // data: {result, res, res2, mongoRes},
       message: '获取成功',
     };
   }
+
+  public async create() {
+    const { ctx } = this;
+    
+    // 获取请求体数据
+    const userData = ctx.request.body;
+    
+    // 参数验证
+    if (!userData.name || !userData.email) {
+      ctx.status = 400;
+      ctx.body = {
+        code: 400,
+        error: '用户名和邮箱是必填项',
+        message: '参数错误',
+      };
+      return;
+    }
+
+    // 邮箱格式验证
+    const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
+    if (!emailRegex.test(userData.email)) {
+      ctx.status = 400;
+      ctx.body = {
+        code: 400,
+        error: '邮箱格式不正确',
+        message: '参数错误',
+      };
+      return;
+    }
+
+    try {
+
+      // 使用startActiveSpan记录用户创建过程
+      const result = await tracer.startActiveSpan('create_user', async (span: Span) => {
+        // 将请求体数据添加到span属性中
+        span.setAttribute('user.name', userData.name);
+        span.setAttribute('user.email', userData.email);
+        span.setAttribute('user.phone', userData.phone || '');
+        span.setAttribute('user.avatar', userData.avatar || '');
+        span.setAttribute('user.status', userData.status || 'active');
+        span.setAttribute('request.timestamp', new Date().toISOString());
+        
+        // 在span内部调用service创建用户
+        const newUser = await ctx.service.user.createUser(userData);
+        console.log('newUser', newUser)
+        // 记录创建结果到span
+        span.setAttribute('user.created_id', newUser.id);
+        span.setAttribute('user.created_time', newUser.createTime);
+        
+        // 结束span
+        span.end();
+        
+        // 返回创建的用户数据
+        return newUser;
+      });
+      
+      ctx.status = 201;
+      ctx.body = {
+        code: 0,
+        data: result,
+        message: '用户创建成功',
+      };
+    } catch (error) {
+      ctx.logger.error('创建用户失败:', error);
+      ctx.status = 500;
+      ctx.body = {
+        code: 500,
+        error: '创建用户失败',
+        message: '服务器内部错误',
+      };
+    }
+  }
 } 

app/router.ts

@@ -10,4 +10,5 @@ export default (app: Application) => {
   // 用户相关接口
   router.get('/api/users', 'user.index');
   router.get('/api/users/:id', 'user.show');
+  router.post('/api/users', 'user.create');
 }; 

app/service/user.ts

@@ -56,4 +56,34 @@ export default class UserService extends Service {
       pageSize,
     };
   }
+
+  public async createUser(userData: any): Promise<any> {
+    const { ctx } = this;
+    ctx.logger.info(`创建新用户，数据: ${JSON.stringify(userData)}`);
+    
+    // 模拟用户ID生成（实际项目中应该使用数据库自增ID或UUID）
+    const userId = Date.now();
+    
+    // 构建新用户对象
+    const newUser = {
+      id: userId,
+      name: userData.name,
+      email: userData.email,
+      phone: userData.phone || null,
+      avatar: userData.avatar || null,
+      status: userData.status || 'active',
+      createTime: new Date().toISOString(),
+      updateTime: new Date().toISOString(),
+    };
+
+    // 这里可以添加数据库插入逻辑
+    // 例如：await this.ctx.model.User.create(newUser);
+    
+    // 模拟数据库操作延迟
+    await new Promise(resolve => setTimeout(resolve, 100));
+    
+    ctx.logger.info(`用户创建成功，ID: ${userId}`);
+    
+    return newUser;
+  }
 } 

instrumentation.ts

@@ -12,7 +12,7 @@ const { MongoDBInstrumentation } = require('@opentelemetry/instrumentation-mongo
 
 // 声明资源属性：指定 service.name
 const resource = new Resource({
-  [SemanticResourceAttributes.SERVICE_NAME]: 'nodejs10-demo', // 重要：自定义服务名，便于区分服务，也可以通过环境变量传入
+  [SemanticResourceAttributes.SERVICE_NAME]: 'nodejs10-demo-6-30', // 重要：自定义服务名，便于区分服务，也可以通过环境变量传入
   // 也可继续加 service.version、deployment.environment 等
 });
 // 使用 OTLP over gRPC 导出器