selderij

logfire.instrument_celery() De methode creëert een overspanning voor elke taak die door de Celery-werker wordt uitgevoerd.

installeren

Installeer logfire met 额外的芹菜:

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

gebruik

U hebt een berichtenmakelaar nodig om Celery uit te voeren. In dit voorbeeld voeren we RabbitMQ uit op een docker-container. U kunt het als volgt uitvoeren:

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

Hier is een minimaal voorbeeld met selderij. Je kunt het uitvoeren met celery -A tasks worker --loglevel=info:

Logfire.configure ()

@ werker _ proces _ init (zwak = niet waar) Def init _ celery _ tracing (* args, * * kwargs): Logvuur. instrument _ selderij ()

App = Selderij ("taken", makelaar = "pyamqp://localhost / /") # (1)!

@ app.taak Zeker toevoegen (x, y): Geeft terug x + y

Toegevoegde vertraging (42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次