pika

15गर्मी

2उत्तर

लॉगर के लिए कोई हैंडलर नहीं मिला "pika.adapters.blocking_connection"

इसी तरह के प्रश्न कस्टम लॉगर का उपयोग करके चारों ओर आधारित होते हैं, मुझे बस डिफ़ॉल्ट/कोई भी उपयोग करने में खुशी नहीं है। मेरा पिका पायथन ऐप चलता है और संदेश प्राप्त करता है लेकिन No handlers could be

21गर्मी

1उत्तर

पिका

के साथ उपयोग करने के लिए किस प्रकार का कनेक्शन मैं यह पता लगाने की कोशिश कर रहा हूं कि मुझे पिका का उपयोग करते समय किस प्रकार का कनेक्शन उपयोग करना चाहिए, मुझे दो विकल्प मिलते हैं जहां तक मैं समझता

5गर्मी

2उत्तर

पिका और गीवेंट

के साथ यादृच्छिक टाइमआउट त्रुटि मैं पिका लाइब्रेरी (गीवेंट द्वारा पैच बंदर) का उपयोग कर अपने गीवेंट कार्यक्रम के भीतर से खरगोश एमक्यू का उपयोग करने की कोशिश कर रहा हूं, गीवेंट यादृच्छिक रूप से टाइमआउट

9गर्मी

2उत्तर

पिका या खरगोश एमक्यू में, मैं कैसे जांचूं कि कोई उपभोक्ता वर्तमान में उपभोग कर रहा है या नहीं?

मैं यह जांचना चाहता हूं कि उपभोक्ता/कार्यकर्तासंदेश का उपभोग करने के लिए मौजूद है या नहीं। अगर वहाँ नहीं है किसी भी कार्यकर्ता, मैं कुछ श्रमिकों (दोनों उपभोक्ताओं और प्रकाशकों के एक मशीन पर हैं) शुरू

14गर्मी

5उत्तर

त्रुटि "अज्ञात वितरण टैग" तब होता है जब मैं पिका (अजगर)

मैं कुछ धागे में प्रक्रिया संदेशों चाहते हैं, लेकिन इस दौरान कोड निष्पादित मैं त्रुटि मिल रही है का उपयोग कर RabbitMQ को पावती संदेशों का प्रयास करें: from __future__ import with_statement import pik

11गर्मी

1उत्तर

Pika + RabbitMQ: prefetch = 1 के लिए basic_qos को सेट करना अभी भी कतार

में सभी संदेशों का उपभोग करने लगता है। मेरे पास एक पायथन कार्यकर्ता क्लाइंट है जो 10 श्रमिकों को स्पिन करता है जो प्रत्येक हुक एक खरगोश एमक्यू कतार पर फैलाता है। इस तरह यह है कि: #!/usr/bin/python wo

12गर्मी

1उत्तर

खरगोश एमक्यू, पिका और पुन: कनेक्शन रणनीति

मैं पब्का का उपयोग खरगोशएमक्यू से डेटा संसाधित करने के लिए कर रहा हूं। जैसा कि मुझे विभिन्न प्रकार की समस्याओं में भागना प्रतीत होता था, मैंने यह देखने के लिए एक छोटा परीक्षण आवेदन लिखने का फैसला किया

5गर्मी

1उत्तर

Pika RabbitMQ क्लाइंट द्वारा असीमित संदेश हैंडलिंग

Pika timed received example के बाद, मैं एक ग्राहक को अधिक समवर्ती अनुरोधों को संभालना चाहता हूं। मेरा सवाल है, अगर हैंडल_डिल्वेवरी किसी भी तरह से नया संदेश प्राप्त किया जा सकता है और पिछले हैंडल_डिल्व

5गर्मी

1उत्तर

rabbitmq टीसीपी बैकप्रेसर का उपयोग कब करता है?

Pika documentation के अनुसार "खरगोश एमक्यू ब्रोकर आपके क्लाइंट को धीमा करने के लिए टीसीपी बैकप्रेसर का उपयोग करता है अगर यह संदेश बहुत तेजी से वितरित कर रहा है।" मैंने बैकप्रेसर कॉलबैक पंजीकृत किया है

9गर्मी

1उत्तर

क्या पिका के माध्यम से खरगोश में कतारों को सूचीबद्ध करने का कोई तरीका है?

मुझे पता है कि हम rabbitmq में कतार सूचीबद्ध करने के लिए ऐसा कर सकते हैं। rabbitmqctl list_queues लेकिन मैं इसे पिका के माध्यम से कैसे कर सकता हूं?