Distributed tracing is the process of tracking the activity resulting from a request to an application. With this feature, you can:
Simply put, distributed tracing is a knowledge tool. One of the most important perks of having it in your project is that deveopers can learn the system by simply following the traces it makes.
See how Uber is using distributed tracing to make sense of large number of microservices and interactions within their product:
A distributed trace is composed of multiple spans, which represent time spent in services or resources of those services.
Each Span has the following:
Spans are typically displayed for your view as a time axis where each span can be unfolded to inpect additional details:
The Tracer interface (available via Trace
facade) creates Spans and understands how to Inject (serialize) and Extract (deserialize) them across process boundaries.
See OpenTracing spec for more details on semantics behind distributed tracing.
This package requires PHP >= 7.1 and Laravel 5.5 or later. We also offer limited Lumen support (basic tracing and http middleware).
First, install the package via Composer:
composer require vinelab/tracing-laravel
After installation, you can publish the package configuration using the vendor:publish
command. This command will publish the tracing.php
configuration file to your config directory:
php artisan vendor:publish --provider="Vinelab\Tracing\TracingServiceProvider"
You may configure the driver and service name in your .env
file:
TRACING_DRIVER=zipkin
TRACING_SERVICE_NAME=orders
You should also add credentials for your respective driver as described in the section below.
For Lumen, see dedicated section with installation instructions.
Use the following environment variables to configure Zipkin:
ZIPKIN_HOST=localhost
ZIPKIN_PORT=9411
If the collector is unreachable via a given hostname, you might see debug messages about that printed with each request. If you want to ignore these in production, simply edit your logging configuration to omit debug
level messages.
Jaeger is not "officially" supported because of the lack of stable instrumentation for PHP.
However, you can still post spans to Jaeger collector with Zipkin driver using Zipkin compatible HTTP endpoint. In fact, that's the recommended way to use this library since Jaeger's UI is just that much more convenient than Zipkin's.
There are some downsides, however:
We'll consider improving Jaeger support once its instrumetation matures.
The package also includes null
driver that discards created spans.
You will work with tracing via a Trace
facade provided by this package.
Starting new trace is as simple as calling startSpan
method with name for a logical operation the span represents:
$span = Trace::startSpan('Create Order');
Often, you need to continue an existing trace which is why startSpan
also accepts additional parameter for span context. SpanContext may be propagated via various channels including HTTP requests, AMQP messages, arrays or even another span:
$spanContext = Trace::extract($request, Formats::ILLUMINATE_HTTP);
$rootSpan = Trace::startSpan('Create Order', $spanContext);
$childSpan = Trace::startSpan('Validate Order', $rootSpan->getContext())
The possibilities are limitless. Refer to Context Propagation section for more details.
Override span name:
$span->setName('Create Order');
Add tags, which may be used as lookup keys (to search span on UI) or additional details:
$span->tag('shipping_method', $shipping_method);
You can retrieve the current span, which is also your most recently created span:
$span = Trace::getCurrentSpan()
The first span you create when processing a request in the service is called a root span (not to mix with the global root span of the trace):
After you call flush, the root span is reset.
$span = Trace::getRootSpan()
You may finish the span by calling finish
on it. Span duration is derived by subtracting the start timestamp from this:
$span->finish()
You can log additional data between span start and finish. For example, annotate
creates a time-stamped event to explain latencies:
$span->annotate('Order Validated')
Flush refers to the process of sending all pending spans to the transport. It will also reset the state of the tracer including the active spans and UUID:
Trace::flush()
Most of the time though you don't need to explicitly call flush
. Since PHP is designed to die after each request, we already handle finishing the root span and calling flush upon application shutdown for you.
It's only when processing requests continuously in a loop (e.g. AMQP channels) that you must resort to calling flush
manually.
Each root span is associated with a unique identifier that can be used to lookup its trace. It is recommended you include it as part of context when reporting errors to bridge the gap between different parts of your monitoring stack:
// Illuminate\Foundation\Exceptions\Handler
/**
* Get the default context variables for logging.
*
* @return array
*/
protected function context()
{
return array_filter([
'userId' => Auth::id(),
'uuid' => Trace::getUUID(),
]);
}
Custom drivers may also support logging structured data (not available in Zipkin) which can be used for integrating tracing with a Log facade:
use Illuminate\Support\Facades\Event;
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
Event::listen(MessageLogged::class, function (MessageLogged $e) {
Tracer::getCurrentSpan()->log((array) $e);
});
}
This package includes a \Vinelab\Tracing\Middleware\TraceRequests
middleware to take care of continuing the trace from incoming HTTP request.
You should register middleware class in the $middleware
property of your app/Http/Kernel.php
class.
The middleware adds the following tags on a root span:
type
(http)request_method
request_path
request_uri
request_headers
request_ip
request_input
response_status
response_headers
response_content
Request and response body are only included for whitelisted content-types. See
logging.content_types
option in yourconfig/tracing.php
.
You can override the default name of the span (which is VERB /path/for/route
) in the controller:
Trace::getRootSpan()->setName('Create Order')
Lumen does not support this feature, but you can still create traces for commands manually using tracer instance.
Let your console commsands be traced by adding Vinelab\Tracing\Contracts\ShouldBeTraced
interface to your class.
The container span will include the following tags:
type
(cli)argv
The span will be named after the console command. You can override the default name of the span in the command itself:
Trace::getRootSpan()->setName('Mark Orders Expired')
Lumen does not support this feature, but you can still create traces for jobs manually using tracer instance.
Let your queue jobs be traced by adding Vinelab\Tracing\Contracts\ShouldBeTraced
interface to your job class.
The container span will include the following tags:
type
(queue)connection_name
(i.e. sync, redis etc.)queue_name
job_input
As the name implies, job_input
allows you to view your job's contructor parameters as JSON. Serialization of objects to this JSON string can be controlled by implementing one of the following interfaces: Arrayable
, Jsonable
, JsonSerializable
, or a __toString
method. A fallback behavior is to print all your object's public properties.
Constructor arguments must be saved as a class property with the same name (see ProcessPodcast example below).
The span will be named after the queue job class. You can override the default name of the span in the job itself:
app('tracing.queue.span')->setName('Process Podcast')
Note here that the queue span may not necessarily be the root span of the trace. You would usually want the queue to continue the trace from where it left of when the job was dispatched. You can achieve this by simply giving SpanContext to the job's constructor:
class ProcessPodcast implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $podcast;
protected $spanContext;
public function __construct(Podcast $podcast, SpanContext $spanContext)
{
$this->podcast = $podcast;
$this->spanContext = $spanContext;
}
public function handle(AudioProcessor $processor)
{
// Process uploaded podcast...
}
}
The job above can be dispatched like so:
ProcessPodcast::dispatch($podcast, Trace::getRootSpan()->getContext());
The rest will be handled automatically. Note that SpanContext will be excluded from logged job_input
.
This package doesn't automatically handle tracing of queued closures and queued event listeners. You can still trace them manually by opening and closing spans. Improving support for these features might be considered for future versions of the package.
As we talked about previously, the tracer understands how to inject and extract trace context across different applications (services).
We have already seen the example of extracting trace from HTTP request:
$spanContext = Trace::extract($request, Formats::ILLUMINATE_HTTP);
Of course, you don't need to do this manually because this package already includes a middleware to handle this for you, but the trace may not necessarily come from HTTP request.
The second parameter is a format descriptor that tells us how to deserialize tracing headers from given carrier. By default, the following formats are supported:
use Vinelab\Tracing\Propagation\Formats;
$spanContext = Trace::extract($carrier, Formats::TEXT_MAP);
$spanContext = Trace::extract($carrier, Formats::PSR_REQUEST);
$spanContext = Trace::extract($carrier, Formats::ILLUMINATE_HTTP);
$spanContext = Trace::extract($carrier, Formats::AMQP);
$spanContext = Trace::extract($carrier, Formats::GOOGLE_PUBSUB);
You may also add your own format using registerExtractionFormat
method.
Trace::registerExtractionFormat("pubsub", new PubSubExtractor());
The injection format must implement Vinelab\Tracing\Contracts\Extractor
. Refer to default Zipkin implementation for example.
interface Extractor
{
public function extract($carrier): ?SpanContext;
}
Naturally, you can also inject existing trace context from the current span into a given carrier so that another service can continue the trace:
$message = Trace::inject($message, Formats::AMQP);
$channel->basic_publish($message, $this->exchangeName, $routingKey);
By default, the following formats are supported:
use Vinelab\Tracing\Propagation\Formats;
$carrier = Trace::inject($carrier, Formats::TEXT_MAP);
$carrier = Trace::inject($carrier, Formats::PSR_REQUEST);
$carrier = Trace::inject($carrier, Formats::ILLUMINATE_HTTP);
$carrier = Trace::inject($carrier, Formats::AMQP);
$carrier = Trace::inject($carrier, Formats::GOOGLE_PUBSUB);
$carrier = Trace::inject($carrier, Formats::VINELAB_HTTP);
You may also add your own format using registerInjectionFormat
method.
The injection format must implement Vinelab\Tracing\Contracts\Injector
. Refer to default Zipkin implementation for example.
interface Injector
{
public function inject(SpanContext $spanContext, &$carrier): void;
}
You can also use injectContext
method if you need to pass span context explicitly:
$carrier = Trace::injectContext($carrier, Formats::TEXT_MAP, $span->getContext());
IMPORTANT: You don't need to create a custom propagation format if you need to get something done quickly. You can always avail of the default TEXT_MAP
format to inject or extract tracing headers from an associative array.
New drivers must adhere to Vinelab\Tracing\Contracts\Tracer
contract. Refer to the default ZipkinTracer imlementation for example.
use Vinelab\Tracing\Contracts\Extractor;
use Vinelab\Tracing\Contracts\Injector;
use Vinelab\Tracing\Contracts\Span;
use Vinelab\Tracing\Contracts\SpanContext;
public function startSpan(string $name, SpanContext $spanContext = null, ?int $timestamp = null): Span;
public function getRootSpan(): ?Span;
public function getCurrentSpan(): ?Span;
public function getUUID(): ?string;
public function extract($carrier, string $format): ?SpanContext;
public function inject($carrier, string $format);
public function injectContext($carrier, string $format, SpanContext $spanContext);
public function registerExtractionFormat(string $format, Extractor $extractor): array;
public function registerInjectionFormat(string $format, Injector $injector): array;
public function flush(): void;
Once you have written your custom driver, you may register it using the extend method of the TracingDriverManager
. You should call the extend
method from the boot
method of your AppServiceProvider
or any other service provider used by your application. For example, if you have written a JaegerTracer
, you may register it like so:
use Vinelab\Tracing\TracingDriverManager;
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
resolve(TracingDriverManager::class)->extend('jaeger', function () {
return new JaegerTracer;
});
}
Once your driver has been registered, you may specify it as your tracing driver in your environment variables:
TRACING_DRIVER=jaeger
You need to register service provider manually in bootstrap/app.php
file:
$app->register(Vinelab\Tracing\TracingServiceProvider::class);
You should also register middleware in the same file:
$app->middleware([
Vinelab\Tracing\Middleware\TraceRequests::class,
]);
Add the following lines to the end of public/index.php
file:
$tracer = app(Vinelab\Tracing\Contracts\Tracer::class);
optional($tracer->getRootSpan())->finish();
$tracer->flush();
Finally, you may also want to copy over config/tracing.php
from this repo if you need to customize default settings.
If you don't use facades in your Lumen project, you can resolve tracer instance from container like this:
use Vinelab\Tracing\Contracts\Tracer;
app(Tracer::class)->startSpan('Create Order')
Note that Lumen currently doesn't support automatic tracing for console commands and jobs because it doesn't dispatch some events and terminating callbacks. However, you can still create traces manually where you need them.
This package includes optional Vinelab\Tracing\Integration\Concerns\TracesLucidArchitecture
trait to enable tracing for Lucid projects:
class TracingServiceProvider extends ServiceProvider
{
use TracesLucidArchitecture;
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
$this->traceLucidArchitecture();
}
}