सेलेरी: ब्रोकर कनेक्शन पूल तक पहुंच

Question

मैं कॉल करने के लिए एएमक्यूपी ब्रोकर के साथ सेलेरी का उपयोग कर रहा हूं, लेकिन प्रतिक्रिया को सेलेरी के उपयोग से अलग कतार वास्तुकला के साथ वापस पारित करने की आवश्यकता है, इसलिए मैं संदेश को वापस कोम्बू का उपयोग करके पास करना चाहता हूं केवल। मैं यह करने में सक्षम हूं, लेकिन मैं हर बार एक नया कनेक्शन बना रहा हूं। क्या सेलेरी ब्रोकर कनेक्शन पूल का उपयोग करती है, और यदि हां, तो आप इसे कैसे एक्सेस करते हैं?

Answer 1

इसमें बहुत सारी खोज हुई क्योंकि सेलेरी का दस्तावेज है ... अद्भुत ... लेकिन मैं found उत्तर देता हूं।

सेलेरी सबटास्क को कॉल करने के लिए ब्रोकर कनेक्शन पूल का उपयोग करता है। अजवाइन अनुप्रयोग में pool attribute है कि आप <your_app>.pool या celery.current_app.pool के माध्यम से पहुंच सकते हैं। फिर आप pool.acquire() का उपयोग कर पूल से कनेक्शन ले सकते हैं।