Book Image

Mastering Distributed Tracing

By : Yuri Shkuro
Book Image

Mastering Distributed Tracing

By: Yuri Shkuro

Overview of this book

Mastering Distributed Tracing will equip you to operate and enhance your own tracing infrastructure. Through practical exercises and code examples, you will learn how end-to-end tracing can be used as a powerful application performance management and comprehension tool. The rise of Internet-scale companies, like Google and Amazon, ushered in a new era of distributed systems operating on thousands of nodes across multiple data centers. Microservices increased that complexity, often exponentially. It is harder to debug these systems, track down failures, detect bottlenecks, or even simply understand what is going on. Distributed tracing focuses on solving these problems for complex distributed systems. Today, tracing standards have developed and we have much faster systems, making instrumentation less intrusive and data more valuable. Yuri Shkuro, the creator of Jaeger, a popular open-source distributed tracing system, delivers end-to-end coverage of the field in Mastering Distributed Tracing. Review the history and theoretical foundations of tracing; solve the data gathering problem through code instrumentation, with open standards like OpenTracing, W3C Trace Context, and OpenCensus; and discuss the benefits and applications of a distributed tracing infrastructure for understanding, and profiling, complex systems.
Table of Contents (21 chapters)
Mastering Distributed Tracing
Contributors
Preface
Other Books You May Enjoy
Leave a review - let other readers know what you think
15
Afterword
Index

The Span Count job


Let's look at how the SpanCountJob is implemented. The Jaeger collector writes spans to Kafka in Protobuf format, so we need a way to parse them. The package io.jaegertracing.api_v2 is auto-generated by the Protobuf compiler from the IDL file found in the Jaeger codebase (model/proto/model.proto in Jaeger v1.8). Protobuf-generated classes are not particularly convenient to work with in Flink, so in the model package we define a simplified model of the trace that only contains the span data that we need for the purpose of the span count calculations:

public class Span implements Serializable {
    public String traceId;
    public String spanId;
    public String serviceName;
    public String operationName;
    public long startTimeMicros;
    public Map<String, String> tags;
}

The class model.ProtoUnmarshaler is used to convert the spans from the Protobuf model to the simplified Span type. These spans are then aggregated into a Trace type:

public class Trace {
   ...