Le céleri

logfire.instrument_celery() La méthode va créer une envergure pour chaque tâche effectuée par le travailleur Celery.

Installation de

Installer logfire avec 额外的芹菜:

{{ install_logfire(extras=['芹菜']) }}

Utilisation de

Vous avez besoin d'un agent de messagerie pour exécuter Celery. dans cet exemple, nous allons exécuter RabbitMQ sur un conteneur docker. vous pouvez l'exécuter comme suit:

docker run -d --hostname my-rabbit \
    --name some-rabbit \
    # -e RABBITMQ_DEFAULT_USER=user \
    # -e RABBITMQ_DEFAULT_PASS=password \
    rabbitmq:3-management

Ci-dessous, nous avons un exemple minimal d'utilisation du céleri. vous pouvez l'exécuter avec celery -A tasks worker --loglevel=info:

logfire. configure ()

@worker_process_init. connect (weak = False) def init_celery_tracing (* args, ** kwargs): logfire. instrument_celery ()

app = Celery ("tasks ", broker =" pyamqp://localhost//")#(1)!

@app. task Def add (x, y): retour x + y

add. delay (42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

logfire.instrument_celery() 传递给 CeleryInstrumentor().instrument() 方法。

---

本文总阅读量次