сельдерей

logfire.instrument_celery() Метод создает диапазон для каждой задачи, которую выполняет Celery Worker.

Монтаж

Установка logfire с помощью 额外的芹菜:

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

Использование

Вам нужен агент сообщений для запуска Celery. В этом примере мы запустим RabbitMQ на контейнере docker. Вы можете запустить его следующим образом:

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

Ниже у нас есть минимальный пример использования сельдерея. Вы можете запустить его с celery -A tasks worker --loglevel=info:

Логотип ()

worker_process_init.connect (weak=False) definit_celery_tracing (args, *kwargs): Logfire. instrument_celery ()

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

Task @app def add(x, y): Return X + y

add.delay(42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次