在 .NET Core 上使用 Elastic APM 进行分布式跟踪，非 HTTP

Question

我有兴趣在 ASP.NET Core 中使用 Elastic APM 来检测通过混合协议（HTTP、SQS、SNS）进行通信的一组服务的跟踪。尽管查看了文档，但我不清楚如何使用Elastic APM Public API 将发生在 HTTP 之外的事务相互连接（Elastic APM 会自动检测 HttpClient 以进行跟踪）。

根据文档，我应该能够序列化调用者上的CurrentTransaction.OutgoingDistributedTracingData，然后反序列化它以恢复被调用者上的事务，但是尽管在内存中实现了这种模式，但我在 Kibana 中的跟踪缺少所有跨度但最后的交易。

// transaction 1
var trans1 = Agent.Tracer.StartTransaction("Dist Trans 2", ApiConstants.TypeRequest);

await trans1.CaptureSpan("step 1 processing", ApiConstants.ActionExec, async () => await Task.Delay(30));

// transaction 2
var trans2 = Agent.Tracer.StartTransaction("Dist Trans 2", ApiConstants.TypeRequest,
    DistributedTracingData.TryDeserializeFromString(trans1.OutgoingDistributedTracingData.SerializeToString()));

await trans2.CaptureSpan("step 2 processing", ApiConstants.ActionExec, async () => await Task.Delay(30));

// transaction 3
var trans3 = Agent.Tracer.StartTransaction("Dist Trans 2", ApiConstants.TypeRequest,
    DistributedTracingData.TryDeserializeFromString(trans2.OutgoingDistributedTracingData.SerializeToString()));

await trans3.CaptureSpan("step 3 processing", ApiConstants.ActionExec, async () => await Task.Delay(30));

trans3.End();

可以在Github 上找到我的实施高峰。

Answer 1

你不会结束trans1和trans2。

只需将这两行放在它们的结尾处，一切都应该很好：

trans1.End();
trans2.End();

有CaptureTransaction，这是一种方便的方法，可以包装您的任何代码并确保事务结束并捕获所有异常 - 因此您使用该方法，它会为您完成“一切”。

然后是StartTransaction 方法——这是您在代码中使用的方法——它启动事务并且不执行任何其他操作。这里的优势是您可以获得一个ITransaction 实例，您可以随时随地使用它。但在这种情况下，您需要在执行事务（也就是您要捕获的代码）后手动调用.End()。

与CaptureSpan 和StartSpan 相同。

所以您使用CaptureSpan 作为您的跨度，因此当带有Task.Delay 的lambda 完成时自动结束的那些，另一方面您使用StartTransaction 开始您的事务但只在trans3 上调用.End() 和不在其他 2 笔交易中。

有一个演示 here 的一些解释 - 该演示的示例代码是 here。