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 回答