Instrumentation Celery

Installation

🐍 N’oubliez pas d’installer le paquet AppSignal for Python dans votre application au préalable.

Tout d’abord, installez le package opentelemetry-instrumentation-celery. Nous recommandons également d’installer le package d’instrumentation Redis. Pour ajouter les deux packages d’instrumentation à votre projet, ajoutez les lignes suivantes à votre fichier requirements.txt :

<PythonDisableInstrumentations />
# requirements.txt
opentelemetry-instrumentation-celery
opentelemetry-instrumentation-redis

Configuration

Celery nécessite une configuration supplémentaire, car c’est un composant d’application qui démarre séparément.

Comme indiqué dans l’exemple ci-dessous, le module appsignal doit être importé dans le fichier principal utilisé pour démarrer Celery, et la méthode appsignal.start() doit être appelée depuis une méthode portant le décorateur @worker_process_init.connect.

Dans l’exemple ci-dessous, cette initialisation a lieu dans le fichier tasks.py. Ce fichier peut porter un nom différent dans votre application.

# tasks.py

# Import this file
import appsignal

from celery import Celery

# Import this file
from celery.signals import worker_process_init

# Add the init_celery_tracing method with its annotation
@worker_process_init.connect(weak=False)
def init_celery_tracing(*args, **kwargs):
    appsignal.start()

app = Celery('tasks', broker='redis://localhost')

@app.task
def slow_task():
    # Do things

SDK & télémétrie

SDK de langage

Outils de télémétrie

Installation

Configuration

​Installation

​Configuration

Installation

Configuration