如何为Akka应用程序配置OpenTelemata代理

Question

我正在尝试使用OpenTelemetry代理从我用Scala编写的Akka应用程序中导出度量和跟踪，目的是使用OpenSearch中的数据。

我的应用程序的技术堆栈：

• Akka-2.6*

我已经将OpenTelemetry instrumentation运行时依赖项添加到构建中。sbt：

  val runtimeDependencies: Seq[ModuleID] = Seq(
    "io.opentelemetry.instrumentation" % "opentelemetry-instrumentation-api" % otelInstrumentationVersion % "runtime"
  )
...
  libraryDependencies ++= compileDependencies ++ testDependencies ++ runtimeDependencies,

我正在属性文件中传递OpenTelem计配置：

export JAVA_OPTS="... \
-javaagent:lib/opentelemetry/opentelemetry-javaagent-all-v1.6.0.jar \
-Dotel.javaagent.configuration-file=lib/opentelemetry/otel.properties"

我的代码中唯一其他相关的部分是属性文件：

otel.service.name=my-app
otel.traces.exporter=jaeger
otel.propagators=jaeger

我确实在OpenSearch中收到了一些跟踪，但它们是完全不同的，不相关的，而我希望它们是链接的。例如，在RabbitMQ主题上接收到一条消息，它进入一个actor，后者最终发出一个SQL查询。因此，我可以看到每个执行步骤需要多少时间。

我很想能够遵循留档，但我发现OpenTelemeter的配置指南在这一点上很少。

更新：

不确定这是否相关，但我在datapreper上得到一个警告：

2021-09-29T16:50:50,861 [raw-pipeline-prepper-worker-5-thread-1] WARN  com.amazon.dataprepper.plugins.prepper.oteltrace.OTelTraceRawPrepper - Missing trace group for SpanId: 922097e31cf96c72

Answer 1

好的，所以我绕过了这个问题，然后阅读了关于如何支持特定工具的内容。

因此，为了减少跟踪仪表板中的混乱，可以向属性文件中添加以下内容（或通过环境变量添加等效内容）：

otel.instrumentation.rabbitmq.enabled=false
otel.instrumentation.grpc.enabled=false

请注意，我删除了我的用例特有的两个杂乱的工具库。对于另一个应用程序，可以从上面的链接#2中选择其他库。这样，您作为应用程序开发人员声明的跨度将成为根。