Sellerie.

logfire.instrument_celery() Die Methode erstellt eine Spanne für jede Aufgabe, die der Celery-Arbeiter ausführt.

Installiert

Installieren Sie logfire mit 额外的芹菜:

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

Verwendung

In diesem Beispiel führen wir RabbitMQ in einem Docker-Container aus.

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

Hier ist ein minimales Beispiel für die Verwendung von Sellerie, das Sie mit celery -A tasks worker --loglevel=info ausführen können:

logfire. configure ()(Dateiendung)

@ Arbeiter_process_init. connect (weak = False) def init_ciery_tracing (* args, ** kwargs)(init_ciery_tracing (* args, ** kwargs)): Weitere Informationen finden Sie unter logfire. instrument_clery ()

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

@ Aufgabe def hinzufügen (x, y): zurück x + y

Verzögerung (42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次