SDKによるテレメトリーの管理

package otel;  import io.opentelemetry.sdk.OpenTelemetrySdk; import io.opentelemetry.sdk.resources.Resource;  public class OpenTelemetrySdkConfig {  public static OpenTelemetrySdk create() {  Resource resource = ResourceConfig.create();  return OpenTelemetrySdk.builder()  .setTracerProvider(SdkTracerProviderConfig.create(resource))  .setMeterProvider(SdkMeterProviderConfig.create(resource))  .setLoggerProvider(SdkLoggerProviderConfig.create(resource))  .setPropagators(ContextPropagatorsConfig.create())  .build();  } } 

package otel;  import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.semconv.ServiceAttributes;  public class ResourceConfig {  public static Resource create() {  return Resource.getDefault().toBuilder()  .put(ServiceAttributes.SERVICE_NAME, "my-service")  .build();  } } 

package otel;  import io.opentelemetry.sdk.resources.Resource; import io.opentelemetry.sdk.trace.SdkTracerProvider;  public class SdkTracerProviderConfig {  public static SdkTracerProvider create(Resource resource) {  return SdkTracerProvider.builder()  .setResource(resource)  .addSpanProcessor(  SpanProcessorConfig.batchSpanProcessor(  SpanExporterConfig.otlpHttpSpanExporter("http://localhost:4318/v1/spans")))  .setSampler(SamplerConfig.parentBasedSampler(SamplerConfig.traceIdRatioBased(.25)))  .setSpanLimits(SpanLimitsConfig::spanLimits)  .build();  } } 

package otel;  import io.opentelemetry.sdk.extension.trace.jaeger.sampler.JaegerRemoteSampler; import io.opentelemetry.sdk.trace.samplers.Sampler; import java.time.Duration;  public class SamplerConfig {  public static Sampler parentBasedSampler(Sampler root) {  return Sampler.parentBasedBuilder(root)  .setLocalParentNotSampled(Sampler.alwaysOff())  .setLocalParentSampled(Sampler.alwaysOn())  .setRemoteParentNotSampled(Sampler.alwaysOff())  .setRemoteParentSampled(Sampler.alwaysOn())  .build();  }   public static Sampler alwaysOn() {  return Sampler.alwaysOn();  }   public static Sampler alwaysOff() {  return Sampler.alwaysOff();  }   public static Sampler traceIdRatioBased(double ratio) {  return Sampler.traceIdRatioBased(ratio);  }   public static Sampler jaegerRemoteSampler() {  return JaegerRemoteSampler.builder()  .setInitialSampler(Sampler.alwaysOn())  .setEndpoint("http://endpoint")  .setPollingInterval(Duration.ofSeconds(60))  .setServiceName("my-service-name")  .build();  } } 

package otel;  import io.opentelemetry.api.common.Attributes; import io.opentelemetry.api.trace.SpanKind; import io.opentelemetry.context.Context; import io.opentelemetry.sdk.trace.data.LinkData; import io.opentelemetry.sdk.trace.samplers.Sampler; import io.opentelemetry.sdk.trace.samplers.SamplingResult; import java.util.List;  public class CustomSampler implements Sampler {  @Override  public SamplingResult shouldSample(  Context parentContext,  String traceId,  String name,  SpanKind spanKind,  Attributes attributes,  List<LinkData> parentLinks) {  // スパンが開始されたときに呼び出されるコールバック（SpanProcessorが呼び出される前）。  // SamplingDecisionが:  // - DROP: スパンがドロップされます。有効なスパンコンテキストが作成され、SpanProcessor#onStartは  // まだ呼び出されますが、データは記録されず、SpanProcessor#onEndは呼び出されません。  // - RECORD_ONLY: スパンは記録されますがサンプリングされません。データはスパンに記録され、  // SpanProcessor#onStartとSpanProcessor#onEndが呼び出されますが、スパンのサンプリングステータスは  // プロセス外にエクスポートされるべきではないことを示します。  // - RECORD_AND_SAMPLE: スパンは記録およびサンプリングされます。データはスパンに記録され、  // SpanProcessor#onStartとSpanProcessor#onEndが呼び出され、スパンのサンプリングステータスは  // プロセス外にエクスポートされるべきであることを示します。  return SpanKind.SERVER == spanKind ? SamplingResult.recordAndSample() : SamplingResult.drop();  }   @Override  public String getDescription() {  // サンプラーの説明を返します。  return this.getClass().getSimpleName();  } } 

package otel;  import io.opentelemetry.sdk.trace.SpanProcessor; import io.opentelemetry.sdk.trace.export.BatchSpanProcessor; import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; import io.opentelemetry.sdk.trace.export.SpanExporter; import java.time.Duration;  public class SpanProcessorConfig {  public static SpanProcessor batchSpanProcessor(SpanExporter spanExporter) {  return BatchSpanProcessor.builder(spanExporter)  .setMaxQueueSize(2048)  .setExporterTimeout(Duration.ofSeconds(30))  .setScheduleDelay(Duration.ofSeconds(5))  .build();  }   public static SpanProcessor simpleSpanProcessor(SpanExporter spanExporter) {  return SimpleSpanProcessor.builder(spanExporter).build();  } } 

package otel;  import io.opentelemetry.context.Context; import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.trace.ReadWriteSpan; import io.opentelemetry.sdk.trace.ReadableSpan; import io.opentelemetry.sdk.trace.SpanProcessor;  public class CustomSpanProcessor implements SpanProcessor {   @Override  public void onStart(Context parentContext, ReadWriteSpan span) {  // スパンが開始されたときに呼び出されるコールバック。  // カスタム属性でレコードをエンリッチします。  span.setAttribute("my.custom.attribute", "hello world");  }   @Override  public boolean isStartRequired() {  // onStartが呼び出されるべきかどうかを示します。  return true;  }   @Override  public void onEnd(ReadableSpan span) {  // スパンが終了されたときに呼び出されるコールバック。  }   @Override  public boolean isEndRequired() {  // onEndが呼び出されるべきかどうかを示します。  return false;  }   @Override  public CompletableResultCode shutdown() {  // オプションでプロセッサーをシャットダウンし、リソースをクリーンアップします。  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode forceFlush() {  // オプションでキューに入れられているがまだ処理されていないレコードを処理します。  return CompletableResultCode.ofSuccess();  } } 

package otel;  import io.opentelemetry.exporter.logging.LoggingSpanExporter; import io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingSpanExporter; import io.opentelemetry.exporter.otlp.http.trace.OtlpHttpSpanExporter; import io.opentelemetry.exporter.otlp.trace.OtlpGrpcSpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter; import java.time.Duration;  public class SpanExporterConfig {  public static SpanExporter otlpHttpSpanExporter(String endpoint) {  return OtlpHttpSpanExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static SpanExporter otlpGrpcSpanExporter(String endpoint) {  return OtlpGrpcSpanExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static SpanExporter logginSpanExporter() {  return LoggingSpanExporter.create();  }   public static SpanExporter otlpJsonLoggingSpanExporter() {  return OtlpJsonLoggingSpanExporter.create();  } } 

package otel;  import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.trace.data.SpanData; import io.opentelemetry.sdk.trace.export.SpanExporter; import java.util.Collection; import java.util.logging.Level; import java.util.logging.Logger;  public class CustomSpanExporter implements SpanExporter {   private static final Logger logger = Logger.getLogger(CustomSpanExporter.class.getName());   @Override  public CompletableResultCode export(Collection<SpanData> spans) {  // レコードをエクスポートします。通常、レコードは何らかのネットワークプロトコルを介してプロセス外に送信されますが、  // 説明のためにここでは単にログ出力します。  logger.log(Level.INFO, "Exporting spans");  spans.forEach(span -> logger.log(Level.INFO, "Span: " + span));  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode flush() {  // キューに入れられているがまだエクスポートされていないレコードをエクスポートします。  logger.log(Level.INFO, "flushing");  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode shutdown() {  // エクスポーターをシャットダウンし、リソースをクリーンアップします。  logger.log(Level.INFO, "shutting down");  return CompletableResultCode.ofSuccess();  } } 

package otel;  import io.opentelemetry.sdk.trace.SpanLimits;  public class SpanLimitsConfig {  public static SpanLimits spanLimits() {  return SpanLimits.builder()  .setMaxNumberOfAttributes(128)  .setMaxAttributeValueLength(1024)  .setMaxNumberOfLinks(128)  .setMaxNumberOfAttributesPerLink(128)  .setMaxNumberOfEvents(128)  .setMaxNumberOfAttributesPerEvent(128)  .build();  } } 

package otel;  import io.opentelemetry.sdk.metrics.SdkMeterProvider; import io.opentelemetry.sdk.metrics.SdkMeterProviderBuilder; import io.opentelemetry.sdk.resources.Resource; import java.util.List; import java.util.Set;  public class SdkMeterProviderConfig {  public static SdkMeterProvider create(Resource resource) {  SdkMeterProviderBuilder builder =  SdkMeterProvider.builder()  .setResource(resource)  .registerMetricReader(  MetricReaderConfig.periodicMetricReader(  MetricExporterConfig.otlpHttpMetricExporter(  "http://localhost:4318/v1/metrics")));  // カーディナリティ制限付きでメトリクスリーダーを登録するオプションのコメントアウト解除  // builder.registerMetricReader(  // MetricReaderConfig.periodicMetricReader(  // MetricExporterConfig.otlpHttpMetricExporter("http://localhost:4318/v1/metrics")),  // instrumentType -> 100);   ViewConfig.dropMetricView(builder, "some.custom.metric");  ViewConfig.histogramBucketBoundariesView(  builder, "http.server.request.duration", List.of(1.0, 5.0, 10.0));  ViewConfig.attributeFilterView(  builder, "http.client.request.duration", Set.of("http.request.method"));  ViewConfig.cardinalityLimitsView(builder, "http.server.active_requests", 100);  return builder.build();  } } 

package otel;  import io.opentelemetry.exporter.prometheus.PrometheusHttpServer; import io.opentelemetry.sdk.metrics.export.MetricExporter; import io.opentelemetry.sdk.metrics.export.MetricReader; import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader; import java.time.Duration;  public class MetricReaderConfig {  public static MetricReader periodicMetricReader(MetricExporter metricExporter) {  return PeriodicMetricReader.builder(metricExporter).setInterval(Duration.ofSeconds(60)).build();  }   public static MetricReader prometheusMetricReader() {  return PrometheusHttpServer.builder().setHost("localhost").setPort(9464).build();  } } 

package otel;  import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.common.export.MemoryMode; import io.opentelemetry.sdk.metrics.Aggregation; import io.opentelemetry.sdk.metrics.InstrumentType; import io.opentelemetry.sdk.metrics.data.AggregationTemporality; import io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector; import io.opentelemetry.sdk.metrics.export.CollectionRegistration; import io.opentelemetry.sdk.metrics.export.MetricReader; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; import java.util.logging.Level; import java.util.logging.Logger;  public class CustomMetricReader implements MetricReader {   private static final Logger logger = Logger.getLogger(CustomMetricExporter.class.getName());   private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);  private final AtomicReference<CollectionRegistration> collectionRef =  new AtomicReference<>(CollectionRegistration.noop());   @Override  public void register(CollectionRegistration collectionRegistration) {  // SdkMeterProviderが初期化されたときに呼び出されるコールバックで、メトリクスを収集するハンドルを提供します。  collectionRef.set(collectionRegistration);  executorService.scheduleWithFixedDelay(this::collectMetrics, 0, 60, TimeUnit.SECONDS);  }   private void collectMetrics() {  // メトリクスを収集します。通常、レコードは何らかのネットワークプロトコルを介してプロセス外に送信されますが、  // 説明のためにここでは単にログ出力します。  logger.log(Level.INFO, "Collecting metrics");  collectionRef  .get()  .collectAllMetrics()  .forEach(metric -> logger.log(Level.INFO, "Metric: " + metric));  }   @Override  public CompletableResultCode forceFlush() {  // キューに入れられているがまだエクスポートされていないレコードをエクスポートします。  logger.log(Level.INFO, "flushing");  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode shutdown() {  // エクスポーターをシャットダウンし、リソースをクリーンアップします。  logger.log(Level.INFO, "shutting down");  return CompletableResultCode.ofSuccess();  }   @Override  public AggregationTemporality getAggregationTemporality(InstrumentType instrumentType) {  // InstrumentTypeの関数として必要な集約時間性を指定  return AggregationTemporalitySelector.deltaPreferred()  .getAggregationTemporality(instrumentType);  }   @Override  public MemoryMode getMemoryMode() {  // オプションでメモリモードを指定し、メトリクスレコードが再利用可能か不変である必要があるかを示します  return MemoryMode.REUSABLE_DATA;  }   @Override  public Aggregation getDefaultAggregation(InstrumentType instrumentType) {  // オプションで計装種別の関数としてデフォルト集約を指定  return Aggregation.defaultAggregation();  } } 

package otel;  import io.opentelemetry.exporter.logging.LoggingMetricExporter; import io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter; import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter; import io.opentelemetry.exporter.otlp.metrics.OtlpGrpcMetricExporter; import io.opentelemetry.sdk.metrics.export.MetricExporter; import java.time.Duration;  public class MetricExporterConfig {  public static MetricExporter otlpHttpMetricExporter(String endpoint) {  return OtlpHttpMetricExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static MetricExporter otlpGrpcMetricExporter(String endpoint) {  return OtlpGrpcMetricExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static MetricExporter logginMetricExporter() {  return LoggingMetricExporter.create();  }   public static MetricExporter otlpJsonLoggingMetricExporter() {  return OtlpJsonLoggingMetricExporter.create();  } } 

package otel;  import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.common.export.MemoryMode; import io.opentelemetry.sdk.metrics.Aggregation; import io.opentelemetry.sdk.metrics.InstrumentType; import io.opentelemetry.sdk.metrics.data.AggregationTemporality; import io.opentelemetry.sdk.metrics.data.MetricData; import io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector; import io.opentelemetry.sdk.metrics.export.MetricExporter; import java.util.Collection; import java.util.logging.Level; import java.util.logging.Logger;  public class CustomMetricExporter implements MetricExporter {   private static final Logger logger = Logger.getLogger(CustomMetricExporter.class.getName());   @Override  public CompletableResultCode export(Collection<MetricData> metrics) {  // レコードをエクスポートします。通常、レコードは何らかのネットワークプロトコルを介してプロセス外に送信されますが、  // 説明のためにここでは単にログ出力します。  logger.log(Level.INFO, "Exporting metrics");  metrics.forEach(metric -> logger.log(Level.INFO, "Metric: " + metric));  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode flush() {  // キューに入れられているがまだエクスポートされていないレコードをエクスポートします。  logger.log(Level.INFO, "flushing");  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode shutdown() {  // エクスポーターをシャットダウンし、リソースをクリーンアップします。  logger.log(Level.INFO, "shutting down");  return CompletableResultCode.ofSuccess();  }   @Override  public AggregationTemporality getAggregationTemporality(InstrumentType instrumentType) {  // 計装種別の関数として必要な集約時間性を指定  return AggregationTemporalitySelector.deltaPreferred()  .getAggregationTemporality(instrumentType);  }   @Override  public MemoryMode getMemoryMode() {  // オプションでメモリモードを指定し、メトリクスレコードが再利用可能か不変である必要があるかを示します  return MemoryMode.REUSABLE_DATA;  }   @Override  public Aggregation getDefaultAggregation(InstrumentType instrumentType) {  // オプションで計装種別の関数としてデフォルト集約を指定  return Aggregation.defaultAggregation();  } } 

package otel;  import io.opentelemetry.sdk.metrics.Aggregation; import io.opentelemetry.sdk.metrics.InstrumentSelector; import io.opentelemetry.sdk.metrics.SdkMeterProviderBuilder; import io.opentelemetry.sdk.metrics.View; import java.util.List; import java.util.Set;  public class ViewConfig {  public static SdkMeterProviderBuilder dropMetricView(  SdkMeterProviderBuilder builder, String metricName) {  return builder.registerView(  InstrumentSelector.builder().setName(metricName).build(),  View.builder().setAggregation(Aggregation.drop()).build());  }   public static SdkMeterProviderBuilder histogramBucketBoundariesView(  SdkMeterProviderBuilder builder, String metricName, List<Double> bucketBoundaries) {  return builder.registerView(  InstrumentSelector.builder().setName(metricName).build(),  View.builder()  .setAggregation(Aggregation.explicitBucketHistogram(bucketBoundaries))  .build());  }   public static SdkMeterProviderBuilder attributeFilterView(  SdkMeterProviderBuilder builder, String metricName, Set<String> keysToRetain) {  return builder.registerView(  InstrumentSelector.builder().setName(metricName).build(),  View.builder().setAttributeFilter(keysToRetain).build());  }   public static SdkMeterProviderBuilder cardinalityLimitsView(  SdkMeterProviderBuilder builder, String metricName, int cardinalityLimit) {  return builder.registerView(  InstrumentSelector.builder().setName(metricName).build(),  View.builder().setCardinalityLimit(cardinalityLimit).build());  } } 

package otel;  import io.opentelemetry.sdk.logs.SdkLoggerProvider; import io.opentelemetry.sdk.resources.Resource;  public class SdkLoggerProviderConfig {  public static SdkLoggerProvider create(Resource resource) {  return SdkLoggerProvider.builder()  .setResource(resource)  .addLogRecordProcessor(  LogRecordProcessorConfig.batchLogRecordProcessor(  LogRecordExporterConfig.otlpHttpLogRecordExporter("http://localhost:4318/v1/logs")))  .setLogLimits(LogLimitsConfig::logLimits)  .build();  } } 

package otel;  import io.opentelemetry.sdk.logs.LogRecordProcessor; import io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor; import io.opentelemetry.sdk.logs.export.LogRecordExporter; import io.opentelemetry.sdk.logs.export.SimpleLogRecordProcessor; import java.time.Duration;  public class LogRecordProcessorConfig {  public static LogRecordProcessor batchLogRecordProcessor(LogRecordExporter logRecordExporter) {  return BatchLogRecordProcessor.builder(logRecordExporter)  .setMaxQueueSize(2048)  .setExporterTimeout(Duration.ofSeconds(30))  .setScheduleDelay(Duration.ofSeconds(1))  .build();  }   public static LogRecordProcessor simpleLogRecordProcessor(LogRecordExporter logRecordExporter) {  return SimpleLogRecordProcessor.create(logRecordExporter);  } } 

package otel;  import io.opentelemetry.api.common.AttributeKey; import io.opentelemetry.context.Context; import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.logs.LogRecordProcessor; import io.opentelemetry.sdk.logs.ReadWriteLogRecord;  public class CustomLogRecordProcessor implements LogRecordProcessor {   @Override  public void onEmit(Context context, ReadWriteLogRecord logRecord) {  // ログレコードが発行されたときに呼び出されるコールバック。  // カスタム属性でレコードをエンリッチします。  logRecord.setAttribute(AttributeKey.stringKey("my.custom.attribute"), "hello world");  }   @Override  public CompletableResultCode shutdown() {  // オプションでプロセッサーをシャットダウンし、リソースをクリーンアップします。  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode forceFlush() {  // オプションでキューに入れられているがまだ処理されていないレコードを処理します。  return CompletableResultCode.ofSuccess();  } } 

package otel;  import io.opentelemetry.exporter.logging.SystemOutLogRecordExporter; import io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingLogRecordExporter; import io.opentelemetry.exporter.otlp.http.logs.OtlpHttpLogRecordExporter; import io.opentelemetry.exporter.otlp.logs.OtlpGrpcLogRecordExporter; import io.opentelemetry.sdk.logs.export.LogRecordExporter; import java.time.Duration;  public class LogRecordExporterConfig {  public static LogRecordExporter otlpHttpLogRecordExporter(String endpoint) {  return OtlpHttpLogRecordExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static LogRecordExporter otlpGrpcLogRecordExporter(String endpoint) {  return OtlpGrpcLogRecordExporter.builder()  .setEndpoint(endpoint)  .addHeader("api-key", "value")  .setTimeout(Duration.ofSeconds(10))  .build();  }   public static LogRecordExporter systemOutLogRecordExporter() {  return SystemOutLogRecordExporter.create();  }   public static LogRecordExporter otlpJsonLoggingLogRecordExporter() {  return OtlpJsonLoggingLogRecordExporter.create();  } } 

package otel;  import io.opentelemetry.sdk.common.CompletableResultCode; import io.opentelemetry.sdk.logs.data.LogRecordData; import io.opentelemetry.sdk.logs.export.LogRecordExporter; import java.util.Collection; import java.util.logging.Level; import java.util.logging.Logger;  public class CustomLogRecordExporter implements LogRecordExporter {   private static final Logger logger = Logger.getLogger(CustomLogRecordExporter.class.getName());   @Override  public CompletableResultCode export(Collection<LogRecordData> logs) {  // レコードをエクスポートします。通常、レコードは何らかのネットワークプロトコルを介してプロセス外に送信されますが、  // 説明のためにここでは単にログ出力します。  System.out.println("Exporting logs");  logs.forEach(log -> System.out.println("log record: " + log));  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode flush() {  // キューに入れられているがまだエクスポートされていないレコードをエクスポートします。  logger.log(Level.INFO, "flushing");  return CompletableResultCode.ofSuccess();  }   @Override  public CompletableResultCode shutdown() {  // エクスポーターをシャットダウンし、リソースをクリーンアップします。  logger.log(Level.INFO, "shutting down");  return CompletableResultCode.ofSuccess();  } } 

package otel;  import io.opentelemetry.sdk.logs.LogLimits;  public class LogLimitsConfig {  public static LogLimits logLimits() {  return LogLimits.builder()  .setMaxNumberOfAttributes(128)  .setMaxAttributeValueLength(1024)  .build();  } } 

package otel;  import io.opentelemetry.api.baggage.propagation.W3CBaggagePropagator; import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator; import io.opentelemetry.context.propagation.ContextPropagators; import io.opentelemetry.context.propagation.TextMapPropagator;  public class ContextPropagatorsConfig {  public static ContextPropagators create() {  return ContextPropagators.create(  TextMapPropagator.composite(  W3CTraceContextPropagator.getInstance(), W3CBaggagePropagator.getInstance()));  } } 

package otel;  import io.opentelemetry.context.Context; import io.opentelemetry.context.propagation.TextMapGetter; import io.opentelemetry.context.propagation.TextMapPropagator; import io.opentelemetry.context.propagation.TextMapSetter; import java.util.Collection; import java.util.Collections;  public class CustomTextMapPropagator implements TextMapPropagator {   @Override  public Collection<String> fields() {  // 伝播に使用されるフィールドを返します。参照実装については W3CTraceContextPropagator を参照してください。  return Collections.emptyList();  }   @Override  public <C> void inject(Context context, C carrier, TextMapSetter<C> setter) {  // コンテキストを注入します。参照実装については W3CTraceContextPropagator を参照してください。  }   @Override  public <C> Context extract(Context context, C carrier, TextMapGetter<C> getter) {  // コンテキストを抽出します。参照実装については W3CTraceContextPropagator を参照してください。  return context;  } } 

## すべてのOpenTelemetryログを無効にする io.opentelemetry.level = OFF 

## BatchSpanProcessorのログのみを無効にする io.opentelemetry.sdk.trace.export.BatchSpanProcessor.level = OFF 

## デバッグに役立つ「FINE」メッセージをログ出力 io.opentelemetry.level = FINE  ## デフォルトのConsoleHandlerのロガーのレベルを設定 ## これはOpenTelemetry以外のログにも影響することに注意 java.util.logging.ConsoleHandler.level = FINE 

// エクスポートからのエラーをログ出力しないカスタムフィルター public class IgnoreExportErrorsFilter implements java.util.logging.Filter {   public boolean isLoggable(LogRecord record) {  return !record.getMessage().contains("Exception thrown by the export");  } } 

## BatchSpanProcessorにカスタムフィルターを登録 io.opentelemetry.sdk.trace.export.BatchSpanProcessor = io.opentelemetry.extension.logging.IgnoreExportErrorsFilter 

package otel;  import io.opentelemetry.exporter.otlp.http.logs.OtlpHttpLogRecordExporter; import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter; import io.opentelemetry.exporter.otlp.http.trace.OtlpHttpSpanExporter; import java.time.Duration; import java.time.Instant; import java.util.Collections; import java.util.Map; import java.util.function.Supplier;  public class OtlpAuthenticationConfig {  public static void staticAuthenticationHeader(String endpoint) {  // OTLP宛先がAPIキーのような静的で長期間有効な認証ヘッダーを受け入れる場合、  // それをヘッダーとして設定します。  // これは、ソースコードにシークレットをハードコードすることを避けるため、  // OTLP_API_KEY環境変数からAPIキーを読み取ります。  String apiKeyHeaderName = "api-key";  String apiKeyHeaderValue = System.getenv("OTLP_API_KEY");   // 類似のパターンを使用してOTLP Span、Metric、LogRecordエクスポーターを初期化  OtlpHttpSpanExporter spanExporter =  OtlpHttpSpanExporter.builder()  .setEndpoint(endpoint)  .addHeader(apiKeyHeaderName, apiKeyHeaderValue)  .build();  OtlpHttpMetricExporter metricExporter =  OtlpHttpMetricExporter.builder()  .setEndpoint(endpoint)  .addHeader(apiKeyHeaderName, apiKeyHeaderValue)  .build();  OtlpHttpLogRecordExporter logRecordExporter =  OtlpHttpLogRecordExporter.builder()  .setEndpoint(endpoint)  .addHeader(apiKeyHeaderName, apiKeyHeaderValue)  .build();  }   public static void dynamicAuthenticationHeader(String endpoint) {  // OTLP宛先が定期的に更新が必要なJWTなどの動的認証ヘッダーを要求する場合、  // ヘッダーサプライヤーを使用します。  // ここでは「Authorization: Bearer <token>」形式のヘッダーを追加するシンプルなサプライヤーを実装し、  // <token>は10分ごとにrefreshBearerTokenから取得されます。  String username = System.getenv("OTLP_USERNAME");  String password = System.getenv("OTLP_PASSWORD");  Supplier<Map<String, String>> supplier =  new AuthHeaderSupplier(() -> refreshToken(username, password), Duration.ofMinutes(10));   // 類似のパターンを使用してOTLP Span、Metric、LogRecordエクスポーターを初期化  OtlpHttpSpanExporter spanExporter =  OtlpHttpSpanExporter.builder().setEndpoint(endpoint).setHeaders(supplier).build();  OtlpHttpMetricExporter metricExporter =  OtlpHttpMetricExporter.builder().setEndpoint(endpoint).setHeaders(supplier).build();  OtlpHttpLogRecordExporter logRecordExporter =  OtlpHttpLogRecordExporter.builder().setEndpoint(endpoint).setHeaders(supplier).build();  }   private static class AuthHeaderSupplier implements Supplier<Map<String, String>> {  private final Supplier<String> tokenRefresher;  private final Duration tokenRefreshInterval;  private Instant refreshedAt = Instant.ofEpochMilli(0);  private String currentTokenValue;   private AuthHeaderSupplier(Supplier<String> tokenRefresher, Duration tokenRefreshInterval) {  this.tokenRefresher = tokenRefresher;  this.tokenRefreshInterval = tokenRefreshInterval;  }   @Override  public Map<String, String> get() {  return Collections.singletonMap("Authorization", "Bearer " + getToken());  }   private synchronized String getToken() {  Instant now = Instant.now();  if (currentTokenValue == null || now.isAfter(refreshedAt.plus(tokenRefreshInterval))) {  currentTokenValue = tokenRefresher.get();  refreshedAt = now;  }  return currentTokenValue;  }  }   private static String refreshToken(String username, String password) {  // 本番シナリオでは、これはユーザー名/パスワードをベアラートークンに交換するための  // アウトオブバンドリクエストに置き換えられます。  return "abc123";  } }