अजवाइन

logfire.instrument_celery() विधि सेलरी कार्यकर्ता द्वारा किए गए प्रत्येक कार्य के लिए एक अवधि बनाएगी।

स्थापित करें

उपयोग 额外的芹菜 स्थापित करें logfire यह क्या है?

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

उपयोग

सेलरी चलाने के लिए आपको एक संदेश ब्रोकर की आवश्यकता होती है। इस उदाहरण में, हम इसे एक डॉकर कंटेनर पर चलाएंगे रैबिटएमक्यू आप इसे निम्नानुसार चला सकते हैं:

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.configure ()

@ कार्यकर्ता_प्रक्रिया_निट (weak = False) Dinit_celery_tracing (* args, ** kwargs): लॉगफायर। इंस्ट्रूमेंट_सेलरी ()

ऐप = अजवाइन ("कार्य", ब्रोकर = pyamqp://localhost //") # ( 1)!

@ ऐप Dजोड़ें (x, y): x + y लौटाता है

जोड़ा गया देरी (42, 50) ```

1. 使用 pip install pyamqp 安装 pyamqp。

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

---

本文总阅读量次