셀러리

logfire.instrument_celery() 이 방법은 셀러리 작업자가 수행하는 각 작업에 대한 범위를 만듭니다.

설치

사용 额外的芹菜 설치 logfire 그것은 무엇입니까?

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

사용법

셀러리를 실행하려면 메시지 브로커가 필요합니다. 이 예에서는RabbitMQ를 도커 컨테이너에서 실행합니다. 다음과 같이 실행할 수 있습니다.

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 로 실행할 수 있습니다.

Logfire . 구성 ()

@__init (약 = 거짓) Def init_celery_tracing(args, *kwargs): 로그파이어. 악기 _ 셀러리 ()

앱 = 셀러리("작업", 브로커 = "pyamqp://localhost/") # (1)!

@app.작업 데프 추가(x, y): x + y를 반환합니다.

지연 추가(42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次