OpenTelemetry pika instrumentation
Project description
This library allows tracing requests made by the pika library.
Installation
pip install opentelemetry-instrumentation-pika
Usage
Start broker backend
docker run -p 5672:5672 rabbitmq
Run instrumented task
import pika
from opentelemetry.instrumentation.pika import PikaInstrumentor
PikaInstrumentor().instrument()
connection = pika.BlockingConnection(pika.URLParameters('amqp://localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body=b'Hello World!')
PikaInstrumentor also supports instrumentation of a single channel
import pika
from opentelemetry.instrumentation.pika import PikaInstrumentor
connection = pika.BlockingConnection(pika.URLParameters('amqp://localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
pika_instrumentation = PikaInstrumentor()
pika_instrumentation.instrument_channel(channel=channel)
channel.basic_publish(exchange='', routing_key='hello', body=b'Hello World!')
pika_instrumentation.uninstrument_channel(channel=channel)
PikaInstrumentor also supports instrumentation without creating an object, and receiving a tracer_provider
PikaInstrumentor.instrument_channel(channel, tracer_provider=tracer_provider)
References
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for opentelemetry-instrumentation-pika-0.25b0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | d991c7f452da3d22fe341c06041730109ca19055a8f147361e71a8b6ae720fbe |
|
MD5 | 0d76f211bae18aae59442a71fcd60915 |
|
BLAKE2b-256 | 1373a8b7b5b4547c1a314c9bfaa93bf27924f868b60d987d5200cb5b7bda380e |
Close
Hashes for opentelemetry_instrumentation_pika-0.25b0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 26c2f2855ba4109e1fa2b7c095beb160feeb02475cfd42c9d4770311ccb27fe4 |
|
MD5 | e745d30e377eeb19250bcb8a7a19cc6e |
|
BLAKE2b-256 | 576c035d61bff42b4eaed474231024d9d073d3662034a06354cf4245143dd460 |