Async Tracing Instrumentation using OpenTracing API (http://opentracing.io)
A collection of asyncio instrumentation tools to enable tracing with OpenTracing API.
Make sure you are running recent enough versions of
setuptools, e.g. before installing your project requirements execute this:
pip install --upgrade "setuptools>=29" "pip>=9"
The module name is
Supported client frameworks
The following libraries are instrumented for tracing in this module:
- aiobotocore — Asyncio AWS SDK for Python
- aioboto3 — Asyncio AWS SDK for Python (uses aiobotocore under the hood)
- aiohttp - Asyncio HTTP server and client
- Only Python 3.5+ is currently supported.
For inbound requests a helper function
before_request is provided for creating middleware for frameworks like aiohttp and possibly Tornado.
A middleware is provided for
In-process Context Propagation
As part of the OpenTracing 2.0 API, in-process
Span propagation happens through the newly defined
This library provides two types of instrumentation, explicit instrumentation for server endpoints, and implicit instrumentation for client call sites.
Server endpoints are instrumented by creating a (or using a provided) middleware class that:
- initializes the specific tracer implementation
- wraps incoming request handlers into a method that reads the incoming tracing info from the request and creates a new tracing Span
from aiohttp import web from opentracing_async_instrumentation.client_hooks import aiohttpserver async def handler(request): return web.Response(body='Hello World') app = web.Application() app.router.add_get('/', handler) app.middlewares.append(aiohttpserver.enable_tracing) if __name__ == '__main__': web.run_app(app)
Client call sites are instrumented implicitly by executing a set of
client_hooks that monkey-patch some API points in several
common libraries like
aiobotocore. The initialization of
those hooks is usually also done from the middleware class's
Usage is via the
from opentracing_async_instrumentation import client_hooks client_hooks.install_all_patches()
aiohttp library, in case you want to set custom tags
to spans depending on content or some metadata of responses,
you can set
The hook must be a method with a signature
span are positional arguments,
so you can use different names for them if needed.
from opentracing_async_instrumentation.client_hooks.aiohttpclient import patcher def hook(response, span): if not response.ok: span.set_tag('error', 'true') patcher.set_response_handler_hook(hook)
To prepare a development environment please execute the following commands.
virtualenv env source env/bin/activate make bootstrap make test
You can use tox to run tests as well.
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Hashes for opentracing_async_instrumentation-0.1.3.tar.gz
Hashes for opentracing_async_instrumentation-0.1.3-py3-none-any.whl