fix(tracing): disable unused metrics/logging export

Author: ACaiCat

pkg/tracing/provider.go

@@ -19,12 +19,7 @@ package tracing
 import (
 	"context"
 
-	"github.com/cloudwego/kitex/pkg/klog"
 	"github.com/kitex-contrib/obs-opentelemetry/provider"
-	"go.opentelemetry.io/otel"
-	"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc"
-	"go.opentelemetry.io/otel/log/global"
-	sdklog "go.opentelemetry.io/otel/sdk/log"
 	"go.opentelemetry.io/otel/sdk/resource"
 	semconv "go.opentelemetry.io/otel/semconv/v1.4.0"
 )
@@ -39,10 +34,12 @@ func NewOtelProvider(serviceName string, endpoint string) func(context.Context)
 		provider.WithServiceName(serviceName),
 		provider.WithExportEndpoint(endpoint),
 		provider.WithResource(res),
-		provider.WithInsecure())
+		provider.WithInsecure(),
+		provider.WithEnableMetrics(false),
+	)
 
 	// manually written logger provider
-	lp := newOtelLoggerProvider(serviceName, endpoint)
+	// lp := newOtelLoggerProvider(serviceName, endpoint)
 
 	// return shutdown func
 	return func(ctx context.Context) error {
@@ -52,52 +49,54 @@ func NewOtelProvider(serviceName string, endpoint string) func(context.Context)
 			return err
 		}
 
-		if err = lp.Shutdown(ctx); err != nil {
-			otel.Handle(err) // handle by otel
-		}
+		// if err = lp.Shutdown(ctx); err != nil {
+		//	otel.Handle(err) // handle by otel
+		// }
 
 		return err
 	}
 }
 
 // newOtelLoggerProvider 手动初始化 LoggerProvider
-func newOtelLoggerProvider(serviceName string, endpoint string) *sdklog.LoggerProvider {
-	ctx := context.Background()
-
-	res := getResource(ctx, serviceName)
-
-	// log exporter
-	logExp, err := otlploggrpc.New(ctx,
-		otlploggrpc.WithEndpoint(endpoint),
-		otlploggrpc.WithInsecure())
-	if err != nil {
-		klog.Fatalf("failed to create otlp log exporter: %s", err)
-		return nil
-	}
-
-	// log processor
-	bp := sdklog.NewBatchProcessor(logExp)
-
-	// logger provider
-	lp := sdklog.NewLoggerProvider(
-		sdklog.WithResource(res),
-		sdklog.WithProcessor(bp))
-
-	global.SetLoggerProvider(lp)
-
-	return lp
-}
+// func newOtelLoggerProvider(serviceName string, endpoint string) *sdklog.LoggerProvider {
+//	ctx := context.Background()
+//
+//	res := getResource(ctx, serviceName)
+//
+//	// log exporter
+//	logExp, err := otlploggrpc.New(ctx,
+//		otlploggrpc.WithEndpoint(endpoint),
+//		otlploggrpc.WithInsecure())
+//	if err != nil {
+//		klog.Fatalf("failed to create otlp log exporter: %s", err)
+//		return nil
+//	}
+//
+//	// log processor
+//	bp := sdklog.NewBatchProcessor(logExp)
+//
+//	// logger provider
+//	lp := sdklog.NewLoggerProvider(
+//		sdklog.WithResource(res),
+//		sdklog.WithProcessor(bp))
+//
+//	global.SetLoggerProvider(lp)
+//
+//	return lp
+// }
 
 // getResource 一个 tracing/metrics/logging 通用的 Resource
 func getResource(ctx context.Context, serviceName string) *resource.Resource {
 	// 参见 https://github.com/kitex-contrib/obs-opentelemetry/blob/main/provider/provider.go 下 newResource()
-	res, err := resource.New(ctx,
+	res, err := resource.New(
+		ctx,
 		resource.WithHost(),
 		resource.WithFromEnv(),
 		resource.WithProcessPID(),
 		resource.WithTelemetrySDK(),
 		resource.WithAttributes(
-			semconv.ServiceNameKey.String(serviceName)), // service.name
+			semconv.ServiceNameKey.String(serviceName),
+		), // service.name
 	)
 	if err != nil {
 		return resource.Default()