1

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

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

  • 阿卡 - 2.6.*
  • RabbitMQ(amqp 客户端 5.12.*)
  • PostgreSQL (jdbc 42.2.*)

我已将 OpenTelemetry 检测运行时依赖项添加到build.sbt

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

我在属性文件中传递 OpenTelemetry 配置:

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 主题上收到一条消息,它会进入演员,后者最终发出 SQL 查询。结果,我可以看到每次执行每个步骤花费了多少时间。

这是我在 OpenSearch 中得到的近似视图:在此处输入图像描述

我希望能够关注文档,但我发现 OpenTelemetry 的配置指南目前很少。

更新

不确定这是否相关,但我收到有关 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
4

1 回答 1

0

好的,所以我解决了这个问题,然后阅读了有关如何抑制特定仪器的信息。

因此,为了减少跟踪仪表板中的混乱,可以将以下内容添加到属性文件(或通过环境变量等效):

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

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

于 2021-10-14T14:01:56.290 回答