在使用Golang编写的OpenTelemetry导出器方面取得了部分成功。

huangapple
go评论150阅读模式
英文:

Partial succes on opentelemtry exporter in golang

问题

我正在运行一个开放遥测收集器的Pod，它暴露在端口4318上（运行Node.js演示程序完美运行）。

但是运行这个基本的代码示例（基本上只是在初始化跟踪器并发送跨度后运行一个简单的程序）：

  1. package main
  3. import (
  4. 	"context"
  5. 	"fmt"
  6. 	"log"
  7. 	"os"
  8. 	"os/signal"
  9. 	"time"
  11. 	"go.opentelemetry.io/otel"
  13. 	"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp"
  15. 	"go.opentelemetry.io/otel/sdk/resource"
  16. 	sdktrace "go.opentelemetry.io/otel/sdk/trace"
  17. 	semconv "go.opentelemetry.io/otel/semconv/v1.4.0"
  18. )
  20. func initProvider() func() {
  21. 	ctx := context.Background()
  23. 	_, err := resource.New(ctx,
  24. 		resource.WithAttributes(
  25. 			semconv.ServiceNameKey.String("test-service"),
  26. 		),
  27. 	)
  28. 	handleErr(err, "failed to create resource")
  29. 	traceExporter, err := otlptracehttp.New(ctx,
  30. 		otlptracehttp.WithInsecure(),
  31. 		otlptracehttp.WithEndpoint("localhost:4318"),
  32. 	)
  34. 	handleErr(err, "failed to create trace exporter")
  36. 	bsp := sdktrace.NewBatchSpanProcessor(traceExporter)
  37. 	tracerProvider := sdktrace.NewTracerProvider(
  38. 		sdktrace.WithSpanProcessor(bsp),
  39. 	)
  41. 	otel.SetTracerProvider(tracerProvider)
  42. 	return func() {
  43. 		handleErr(tracerProvider.Shutdown(ctx), "failed to shutdown TracerProvider")
  44. 	}
  45. }
  47. func initialize() {
  49. 	traceExp, err := otlptracehttp.New(
  50. 		context.Background(),
  51. 		otlptracehttp.WithEndpoint("127.0.0.1:8082"),
  52. 		otlptracehttp.WithURLPath("v1/traces"),
  53. 		otlptracehttp.WithInsecure(),
  54. 	)
  55. 	if err != nil {
  56. 		fmt.Println(err)
  57. 	}
  59. 	bsp := sdktrace.NewBatchSpanProcessor(traceExp)
  60. 	tracerProvider := sdktrace.NewTracerProvider(
  61. 		sdktrace.WithSpanProcessor(bsp),
  62. 	)
  64. 	otel.SetTracerProvider(tracerProvider)
  65. }
  67. func main() {
  68. 	log.Printf("Waiting for connection...")
  70. 	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt)
  71. 	defer cancel()
  73. 	initProvider()
  75. 	tracer := otel.Tracer("demo-client-tracer")
  76. 	ctx, span := tracer.Start(context.TODO(), "span-name")
  78. 	defer span.End()
  79. 	for i := 0; i < 10; i++ {
  80. 		_, iSpan := tracer.Start(ctx, fmt.Sprintf("Sample-%d", i))
  81. 		log.Printf("Doing really hard work (%d / 10)\n", i+1)
  83. 		<-time.After(time.Second)
  84. 		iSpan.End()
  85. 	}
  87. 	log.Printf("Done!")
  88. }
  90. func handleErr(err error, message string) {
  91. 	if err != nil {
  92. 		log.Fatalf("%s: %v", message, err)
  93. 	}
  94. }

我得到了：

OTLP部分成功：空消息（0个跨度被拒绝）

并且没有发送任何跟踪... 有什么想法吗？我漏掉了什么？

英文:

I'm running a pod of open telemetry collector that is exposed to port 4318 (running node js demo working perfectly)

but running this basic code sample (which basically just running a simple program after initiating the Tracer and sending spans)

  2. package main
  3. import (
  4. &quot;context&quot;
  5. &quot;fmt&quot;
  6. &quot;log&quot;
  7. &quot;os&quot;
  8. &quot;os/signal&quot;
  9. &quot;time&quot;
  10. &quot;go.opentelemetry.io/otel&quot;
  11. &quot;go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp&quot;
  12. // &quot;go.opentelemetry.io/otel/propagation&quot;
  13. &quot;go.opentelemetry.io/otel/sdk/resource&quot;
  14. sdktrace &quot;go.opentelemetry.io/otel/sdk/trace&quot;
  15. semconv &quot;go.opentelemetry.io/otel/semconv/v1.4.0&quot;
  16. )
  17. func initProvider() func() {
  18. ctx := context.Background()
  19. _, err := resource.New(ctx,
  20. resource.WithAttributes(
  21. semconv.ServiceNameKey.String(&quot;test-service&quot;),
  22. ),
  23. )
  24. handleErr(err, &quot;failed to create resource&quot;)
  25. traceExporter, err := otlptracehttp.New(ctx,
  26. otlptracehttp.WithInsecure(),
  27. otlptracehttp.WithEndpoint(&quot;localhost:4318&quot;),
  28. )
  29. handleErr(err, &quot;failed to create trace exporter&quot;)
  30. bsp := sdktrace.NewBatchSpanProcessor(traceExporter)
  31. tracerProvider := sdktrace.NewTracerProvider(
  32. // sdktrace.WithSampler(sdktrace.AlwaysSample()),
  33. // sdktrace.WithResource(res),
  34. sdktrace.WithSpanProcessor(bsp),
  35. )
  36. otel.SetTracerProvider(tracerProvider)
  37. // otel.SetTextMapPropagator(propagation.TraceContext{})
  38. return func() {
  39. handleErr(tracerProvider.Shutdown(ctx), &quot;failed to shutdown TracerProvider&quot;)
  40. }
  41. }
  42. func initialize() {
  43. traceExp, err := otlptracehttp.New(
  44. context.Background(),
  45. otlptracehttp.WithEndpoint(&quot;127.0.0.1:8082&quot;),
  46. otlptracehttp.WithURLPath(&quot;v1/traces&quot;),
  47. otlptracehttp.WithInsecure(),
  48. )
  49. if err != nil {
  50. fmt.Println(err)
  51. }
  52. bsp := sdktrace.NewBatchSpanProcessor(traceExp)
  53. tracerProvider := sdktrace.NewTracerProvider(
  54. sdktrace.WithSpanProcessor(bsp),
  55. )
  56. otel.SetTracerProvider(tracerProvider)
  57. }
  58. func main() {
  59. log.Printf(&quot;Waiting for connection...&quot;)
  60. ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt)
  61. defer cancel()
  62. // shutdown := initProvider()
  63. // defer shutdown()
  64. initProvider()
  65. tracer := otel.Tracer(&quot;demo-client-tracer&quot;)
  66. ctx, span := tracer.Start(context.TODO(), &quot;span-name&quot;)
  67. defer span.End()
  68. for i := 0; i &lt; 10; i++ {
  69. _, iSpan := tracer.Start(ctx, fmt.Sprintf(&quot;Sample-%d&quot;, i))
  70. log.Printf(&quot;Doing really hard work (%d / 10)\n&quot;, i+1)
  71. &lt;-time.After(time.Second)
  72. iSpan.End()
  73. }
  74. log.Printf(&quot;Done!&quot;)
  75. }
  76. func handleErr(err error, message string) {
  77. if err != nil {
  78. log.Fatalf(&quot;%s: %v&quot;, message, err)
  79. }
  80. }

and Im getting :

  1. OTLP partial success: empty message (0 spans rejected)

and no traces is being sent...
any ideas?
what am I missing ?

答案1

得分: 1

这是OTLP导出器和收集器之间的一个错误，应该在v1.11.2版本中解决。升级到最新版本的go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp应该可以解决这个问题。

英文:

This was a bug between the OTLP exporter and collector that should have been resolved in the v1.11.2 release. Upgrading to the latest version of the go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp should resolve this.

huangapple
  • 本文由 发表于 2022年11月17日 17:49:09
  • 转载请务必保留本文链接：https://go.coder-hub.com/74473295.html
  • go
  • open-telemetry
  • trace
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定