feat: log Inquire_V2(userId, query) and openAI response(id)

Author: odoldotol

contextTracing

@@ -85,7 +85,7 @@
   [V] fix MarketChild exists - 주의 관찰 및 개선 필요함
 
 
-[] OpenTelemetry 이용해서 Context 추적가능하게 로깅하기 (어디까지나 임시조치임. 전문 계측 도구를 통해 분석하는게 바람직할것임.)
+[V] OpenTelemetry 이용해서 Context 추적가능하게 로깅하기 (어디까지나 임시조치임. 전문 계측 도구를 통해 분석하는게 바람직할것임.)
   [V] OpenTelemetry 를 서버에 적용
     [V] Fix - MarketChild 로 Trace Context 전파 잘 되도록
       => 차일드 컨텍스트 전파 잘된다 확인.
@@ -97,4 +97,9 @@
   [V] HttpLogger 에 trace_id 포함하기
     (MarketChild 는 uvicorn.access 로거를 메인 로거로 쓰고있는데 이거 엉망이구만! 일단 대충 미들웨어로 로거 하나 더 달아줌)
 
-  [] 언제 어떤 작업에서든 trace_id 를 포함해서 로깅할 수 있도록 하기
+  [V] 언제 어떤 작업에서든 trace_id 를 포함해서 로깅할 수 있도록 하기
+  [V] 필요한 부분 로깅하기, CustomConsoleSpanExporter 비활성하기
+
+[] openAI 에도 SDK 사용해서 트레이싱 세팅할 수 있다. 세팅하고 Product > YahooFinanceTickerService 에서 req_id 로깅하는 부분 지우기.
+
+[] 계측 도구 exporter 로 연결해서 사용해보기?

market/src/app/middleware/httpLogger.middleware.ts

@@ -8,10 +8,7 @@ import {
   Response,
   NextFunction
 } from 'express';
-import {
-  trace,
-  context
-} from '@opentelemetry/api';
+import { getTraceId } from 'src/openTelemetry';
 
 @Injectable()
 export class HttpLoggerMiddleware
@@ -39,7 +36,7 @@ export class HttpLoggerMiddleware
     const
     { method, originalUrl } = req,
     { statusCode } = res,
-    traceId = trace.getSpan(context.active())?.spanContext().traceId;
+    traceId = getTraceId();
 
     if (
       originalUrl === '/health' &&

market/src/openTelemetry/getSpanContext.ts

@@ -0,0 +1,7 @@
+import {
+  trace,
+  context,
+  SpanContext
+} from '@opentelemetry/api';
+
+export const getSpanContext = (): SpanContext | undefined => trace.getSpan(context.active())?.spanContext();

market/src/openTelemetry/getSpanId.ts

@@ -0,0 +1,3 @@
+import { getSpanContext } from "./getSpanContext"
+
+export const getSpanId = (): string | undefined => getSpanContext()?.spanId;

market/src/openTelemetry/getTraceId.ts

@@ -0,0 +1,3 @@
+import { getSpanContext } from "./getSpanContext";
+
+export const getTraceId = (): string | undefined => getSpanContext()?.traceId;

market/src/openTelemetry/index.ts

@@ -1,15 +1,18 @@
 import { NodeSDK } from '@opentelemetry/sdk-node';
 import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';
 import { W3CTraceContextPropagator } from '@opentelemetry/core';
-import { SimpleSpanProcessor } from '@opentelemetry/sdk-trace-base';
-import { DebuggerConsoleSpanExporter } from './debuggerConsoleSpanExporter';
+// import { SimpleSpanProcessor } from '@opentelemetry/sdk-trace-base';
+// import { DebuggerConsoleSpanExporter } from './debuggerConsoleSpanExporter';
 
 const sdk = new NodeSDK({
-  spanProcessor: new SimpleSpanProcessor(new DebuggerConsoleSpanExporter()),
+  // spanProcessor: new SimpleSpanProcessor(new DebuggerConsoleSpanExporter()),
   instrumentations: [ getNodeAutoInstrumentations() ],
   textMapPropagator: new W3CTraceContextPropagator(),
 });
 
 sdk.start();
 
-console.log('OpenTelemetry initialized');
+console.log('OpenTelemetry initialized');
+
+export { getSpanId } from './getSpanId';
+export { getTraceId } from './getTraceId';

product/src/app/middleware/httpLogger.middleware.ts

@@ -8,10 +8,7 @@ import {
   Response,
   NextFunction
 } from 'express';
-import {
-  trace,
-  context
-} from '@opentelemetry/api';
+import { getTraceId } from 'src/openTelemetry';
 
 @Injectable()
 export class HttpLoggerMiddleware
@@ -39,7 +36,7 @@ export class HttpLoggerMiddleware
     const
     { method, originalUrl } = req,
     { statusCode } = res,
-    traceId = trace.getSpan(context.active())?.spanContext().traceId;
+    traceId = getTraceId();
 
     if (
       originalUrl === '/health' &&

product/src/kakaoChatbot/kakaoChatbot.service.ts

@@ -24,6 +24,7 @@ import {
 } from 'src/common/interface';
 import { chatbotListMenuButtons } from './const';
 import * as F from '@fxts/core';
+import { getTraceId } from 'src/openTelemetry';
 
 @Injectable()
 export class KakaoChatbotService {
@@ -47,6 +48,9 @@ export class KakaoChatbotService {
     const userId = await this.authSrv.getUserId(skillPayload);
     const query = this.getQueryToInqire(skillPayload);
 
+    // temp
+    this.logger.verbose(`${getTraceId()} | ${userId} | ${query}`);
+
     switch (query) {
       case chatbotListMenuButtons.inquireSubscribedAsset.title:
         return this.inquireSubscribedAsset(skillPayload, userId);

product/src/openTelemetry/getSpanContext.ts

@@ -0,0 +1,7 @@
+import {
+  trace,
+  context,
+  SpanContext
+} from '@opentelemetry/api';
+
+export const getSpanContext = (): SpanContext | undefined => trace.getSpan(context.active())?.spanContext();

product/src/openTelemetry/getSpanId.ts

@@ -0,0 +1,3 @@
+import { getSpanContext } from "./getSpanContext"
+
+export const getSpanId = (): string | undefined => getSpanContext()?.spanId;