opentelemetry-instrumentation-celery 0.12b0

OpenTelemetry Celery Instrumentation

Instrumentation for Celery.

Installation

pip install opentelemetry-instrumentation-celery

Usage

• Start broker backend

::

docker run -p 5672:5672 rabbitmq

• Run instrumented task

from opentelemetry.instrumentation.celery import CeleryInstrumentor

CeleryInstrumentor().instrument()

from celery import Celery

app = Celery("tasks", broker="amqp://localhost")

@app.task
def add(x, y):
    return x + y

add.delay(42, 50)

References

• OpenTelemetry Celery Instrumentation

• OpenTelemetry Project