celery

9गर्मी

1उत्तर

एक अजवाइन कार्यकर्ता कब RabbitMQ को स्वीकार करता है कि इसका कोई कार्य है?

मुझे यह गलतफहमी हो सकती है कि यह कैसे काम करता है (यही कारण है कि मैं पूछ रहा हूं), लेकिन मुझे लगता है कि जब एक अजवाइन कार्यकर्ता खरगोश एमक्यू से एक कार्य का उपभोग करता है तो यह उस पर एक ताला लगा देता

9गर्मी

1उत्तर

मौजूदा खरगोश एमक्यू संदेशों के साथ सेलेरी का उपयोग

मेरे पास एक मौजूदा RabbitMQ परिनियोजन है कि कुछ जावा एप्लिकेशन विभिन्न चैनलों पर स्ट्रिंग JSON ऑब्जेक्ट्स के रूप में प्रेषण लॉग संदेशों का उपयोग कर रहे हैं। मैं इन संदेशों का उपभोग करने के लिए सेलेरी

10गर्मी

2उत्तर

हो रही त्रुटि 'mytasks.add'

प्रकार के अपंजीकृत कार्य प्राप्त मैं एक फ़ाइल mytasks.py from celery import Celery celery = Celery("tasks", broker='redis://localhost:6379/0', backend='redis') @celery.task def a

5गर्मी

2उत्तर

Django-celery

के माध्यम से निकट-एकमात्र निष्पादन के लिए हजारों एक-ऑफ (गैर-पुन: प्रयोजन) कार्यों को शेड्यूल करना कुछ संदर्भ: मैं एक Django ऐप बना रहा हूं जो उपयोगकर्ता को एक क्रिया को पूर्व-सहेजने और सटीक तिथि निर्ध

12गर्मी

3उत्तर

सेलेरी - क्या एक ही समय में दो या दो से अधिक श्रमिकों द्वारा खरगोश एमक्यू में एक संदेश खाया जा सकता है?

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

12गर्मी

1उत्तर

ही RabbitMQ दलाल बैकएंड प्रक्रिया

के साथ बहु अजवाइन परियोजनाओं मैं कैसे दो अलग अजवाइन परियोजना जो एकल RabbitMQ स्थापना से संदेश की खपत का उपयोग कर सकते हैं। आम तौर पर, यदि मैं उनके लिए विभिन्न खरगोश का उपयोग करता हूं तो ये स्क्रिप्ट ठ

15गर्मी

3उत्तर

अजवाइन। प्रक्रियाओं की संख्या घटाएं

celery में श्रमिकों की संख्या सीमित करने के लिए कोई रास्ता है? मेरे पास छोटा सर्वर है और अजवाइन हमेशा 1 कोर प्रोसेसर पर 10 प्रक्रियाएं बनाता है। मैं इस नंबर को 3 प्रक्रियाओं तक सीमित करना चाहता हूं।

5गर्मी

1उत्तर

Django-अजवाइन एकाधिक सर्वर उत्पादन वातावरण में

मैं Django का उपयोग कर एक Django परियोजना को तैनात करने की कोशिश कर रहा है, लेकिन मैं इन सवालों अनसुलझी है: मैं हर वेब सर्वर के लिए एक celeryd चलाने चाहिए? क्या मुझे केवल एक खरगोश एमक्यू सर्वर चलाया ज

5गर्मी

1उत्तर

को

का अनियंत्रित कार्य प्राप्त हुआ है, मैं स्मृति में मौजूद कार्यों को चलाने की कोशिश कर रहा हूं। कार्यकर्ता [2012-09-13 11:10:18,928: WARNING/PoolWorker-1] [u'B.run', u'M1.run', u'M11.run', u'M22.run',

7गर्मी

2उत्तर

अजवाइन के लिए कॉलबैक apply_async

मैं आवधिक कार्यों को चलाने के लिए अपने आवेदन में celery का उपयोग करता हूं। चलो नीचे from myqueue import Queue @perodic_task(run_every=timedelta(minutes=1)) def process_queue(): queue = Queue()