商品カタログサービス
このサービスは、商品に関する情報を返す役割を担っています。 すべての商品の取得、特定の商品の検索、または個別の商品の詳細を返すために使用できます。
トレース
トレースの初期化
OpenTelemetry SDK は main から initTracerProvider 関数を使用して初期化されます。
func initTracerProvider() *sdktrace.TracerProvider {
ctx := context.Background()
exporter, err := otlptracegrpc.New(ctx)
if err != nil {
log.Fatalf("OTLP Trace gRPC Creation: %v", err)
}
tp := sdktrace.NewTracerProvider(
sdktrace.WithBatcher(exporter),
sdktrace.WithResource(initResource()),
)
otel.SetTracerProvider(tp)
otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))
return tp
}
サービスのシャットダウン時には TracerProvider.Shutdown() を呼び出して、すべてのスパンがエクスポートされるようにしてください。
このサービスでは、main の遅延関数の一部としてこの呼び出しを行っています。
tp := InitTracerProvider()
defer func() {
if err := tp.Shutdown(context.Background()); err != nil {
log.Fatalf("Tracer Provider Shutdown: %v", err)
}
}()
gRPC 自動計装の追加
このサービスは gRPC リクエストを受信しており、それらは main 関数で gRPC サーバーの作成時に計装されます。
srv := grpc.NewServer(
grpc.StatsHandler(otelgrpc.NewServerHandler()),
)
このサービスは発信 gRPC 呼び出しも行い、それらはすべて gRPC クライアントを計装でラップすることで計装されます。
func createClient(ctx context.Context, svcAddr string) (*grpc.ClientConn, error) {
return grpc.DialContext(ctx, svcAddr,
grpc.WithTransportCredentials(insecure.NewCredentials()),
grpc.WithStatsHandler(otelgrpc.NewClientHandler()),
)
}
自動計装されたスパンへの属性の追加
自動計装されたコードの実行中に、コンテキストから現在のスパンを取得できます。
span := trace.SpanFromContext(ctx)
スパンへの属性の追加は、スパンオブジェクトの SetAttributes を使用して行います。
GetProduct 関数では、商品 ID の属性がスパンに追加されます。
span.SetAttributes(
attribute.String("app.product.id", req.Id),
)
スパンステータスの設定
このサービスは、フィーチャーフラグに基づいてエラー条件をキャッチして処理できます。
エラー条件の場合、スパンオブジェクトの SetStatus を使用してスパンステータスが適切に設定されます。
これは GetProduct 関数で確認できます。
msg := fmt.Sprintf("Error: ProductCatalogService Fail Feature Flag Enabled")
span.SetStatus(otelcodes.Error, msg)
スパンイベントの追加
スパンイベントの追加は、スパンオブジェクトの AddEvent を使用して行います。
GetProduct 関数では、エラー条件が処理されたとき、または商品が正常に見つかったときにスパンイベントが追加されます。
span.AddEvent(msg)
メトリクス
メトリクスの初期化
OpenTelemetry SDK は main から initMeterProvider 関数を使用して初期化されます。
func initMeterProvider() *sdkmetric.MeterProvider {
ctx := context.Background()
exporter, err := otlpmetricgrpc.New(ctx)
if err != nil {
log.Fatalf("new otlp metric grpc exporter failed: %v", err)
}
mp := sdkmetric.NewMeterProvider(sdkmetric.WithReader(sdkmetric.NewPeriodicReader(exporter)))
global.SetMeterProvider(mp)
return mp
}
サービスのシャットダウン時には initMeterProvider.Shutdown() を呼び出して、すべてのレコードがエクスポートされるようにしてください。
このサービスでは、main の遅延関数の一部としてこの呼び出しを行っています。
mp := initMeterProvider()
defer func() {
if err := mp.Shutdown(context.Background()); err != nil {
log.Fatalf("Error shutting down meter provider: %v", err)
}
}()
Goランタイム自動計装の追加
Goランタイムは main 関数で計装されます。
err := runtime.Start(runtime.WithMinimumReadMemStatsInterval(time.Second))
if err != nil {
log.Fatal(err)
}
ログ
OpenTelemetry Collector にログを送信するには2つの方法があります。
- Collector に直接送信する
- ファイルまたは
stdoutを経由する
これら両方のアプローチの使用方法は、手動計装ドキュメントのログセクションに記載されています。
商品カタログサービスはログを直接 Collector に送信し、ログブリッジを使用して slog ログパッケージにブリッジし、構造化ログを出力します。
LoggerProvider の初期化
OpenTelemetry SDK は main から initLoggerProvider 関数を使用して初期化されます。
ctx := context.Background()
logExporter, err := otlploggrpc.New(ctx)
if err != nil {
return nil
}
loggerProvider := sdklog.NewLoggerProvider(
sdklog.WithProcessor(sdklog.NewBatchProcessor(logExporter)),
)
global.SetLoggerProvider(loggerProvider)
return loggerProvider
サービスのシャットダウン時には LoggerProvider.Shutdown() を呼び出して、すべてのログがエクスポートされるようにしてください。
このサービスでは、main の遅延関数の一部としてこの呼び出しを行っています。
lp := initLoggerProvider()
defer func() {
if err := lp.Shutdown(context.Background()); err != nil {
logger.Error(fmt.Sprintf("Logger Provider Shutdown: %v", err))
}
logger.Info("Shutdown logger provider")
}()
ログ機能
このサービスは gRPC 呼び出しを使用して Collector にログを送信します。
ログは slog パッケージを使用して構造化された形式で出力されます。
まず、ロガーを初期化します。
logger *slog.Logger
logger = otelslog.NewLogger("product-catalog")
ロガーに送信する前に、出力をフォーマットするために fmt.Sprintf を使用していることに注目してください。
logger.Info("Loading Product Catalog...")
logger.Info(fmt.Sprintf("Product Catalog reload interval: %d", interval))
logger.Error(fmt.Sprintf("Error shutting down meter provider: %v", err))
slog を使用する利点は、出力に追加の属性を付与できることです。
以下の例では product.name と product.id の属性を付与しています。
これにより、ログ出力の一部としてこれらを表示・解析でき、Grafana で個別のカラムとして表示しやすくなります。
logger.LogAttrs(
ctx,
slog.LevelInfo, "Product Found",
slog.String("app.product.name", found.Name),
slog.String("app.product.id", req.Id),
)
フィードバック
このページは役に立ちましたか?
Thank you. Your feedback is appreciated!
Please let us know how we can improve this page. Your feedback is appreciated!