seledri

logfire.instrument_celery() Metode ini akan membuat rentang untuk setiap tugas yang dilakukan oleh pekerja Seledri.

menginstal

menggunakan 额外的芹菜 menginstal logfire Apa itu?

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

penggunaan

Anda memerlukan broker pesan untuk menjalankan Seledri. Dalam contoh ini, kita akan menjalankan RabbitMQ pada wadah dok. Anda dapat menjalankannya sebagai berikut:

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

Berikut adalah contoh minimal menggunakan seledri. Anda dapat menjalankannya dengan celery -A tasks worker --loglevel=info:

Logfire. Konfigurasi ()

@ pekerja _ proses _ init (lemah = Salah) Def init _ seledri _ tracing (* args, * * kwargs): Logfire. instrumen _ seledri ()

App = Seledri ("tugas," broker = "pyamqp://localhost / /") # (1)!

@ tugas selesai Def tambahkan (x, y): Pengembalian x + y

Penundaan tambahan (42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次