opentelemetry-instrumentor-dramatiq 0.1.0

An instrumentor for dramatiq library

opentelemetry-instrumentor-dramatiq

Opentelemetry traces instrumentation for Dramatiq (An async processing library for python)

Installation

pip install opentelemetry-instrumentor-dramatiq

Usage

import dramatiq
from opentelemetry import trace
from opentelemetry.instrumentation.dramatiq import DramatiqInstrumentor

tracer = trace.get_tracer(__name__)

# Instrument the dramatiq library at the start of your application
DramatiqInstrumentor().instrument()

@dramatiq.actor(queue_name="default")
@tracer.start_as_current_span("my_actor")  # trace the actor
def my_actor(message):
    print(message)

my_actor.send("Hello, world!")

Contributing

Contributions are welcome!