नमस्ते!
मुझे लगता है कि ज्यादातर Django डेवलपर्स ने अजवाइन , एक अतुल्यकालिक कार्य निष्पादन प्रणाली के बारे में सुना है, और कई इसे सक्रिय रूप से उपयोग करते हैं।

लगभग एक साल पहले, हब पर एक अच्छा लेख था जिसमें अजवाइन का उपयोग करने के तरीके के बारे में बात की गई थी। हालांकि, जैसा कि निष्कर्ष में उल्लेख किया गया है, elery 2.0 पहले ही जारी किया जा चुका है (2.2.7 वर्तमान में स्थिर संस्करण है), जहां django के साथ एकीकरण को एक अलग पैकेज में स्थानांतरित किया गया है, साथ ही साथ अन्य परिवर्तन भी ।

यह लेख मुख्य रूप से शुरुआती लोगों के लिए उपयोगी होगा जो Django के साथ काम करना शुरू करते हैं, और उन्हें कुछ ऐसा चाहिए जो सिस्टम में एसिंक्रोनस और / या आवधिक कार्य कर सकें (उदाहरण के लिए, पुराने सत्रों की सफाई)। मैं दिखाऊंगा कि शुरू से अंत तक Django के साथ काम करने के लिए अजवाइन कैसे स्थापित करें और कॉन्फ़िगर करें, साथ ही साथ कुछ अन्य उपयोगी सेटिंग्स और नुकसान भी।


सबसे पहले, सिस्टम में पायथन-सेप्टूपूल पैकेज की उपस्थिति की जांच करें और अनुपस्थिति की स्थिति में इसे स्थापित करें:

aptitude install python-setuptools 

अजवाइन स्थापना

अजवाइन खुद को स्थापित करना बहुत आसान है:

 easy_install Celery 

मूल में अधिक विवरण: http://celeryq.org/docs/getting-started/introduction.html#installation

लेख में, जो लिंक शुरुआत में दिया गया था, MongoDB एक बैकएंड के रूप में उपयोग किया गया था , यहां मैं दिखाऊंगा कि बैकेंड और संदेश ब्रोकर के रूप में एक ही डेटाबेस का उपयोग कैसे करें जिसमें अन्य Django एप्लिकेशन डेटा संग्रहीत करते हैं।

Django-अजवाइन

Django-celery पैकेज स्थापित करें:

 easy_install django-celery 

जैसा कि पहले ही उल्लेख किया गया है, django-celery सेलेरी और Django का एक सुविधाजनक एकीकरण प्रदान करता है। विशेष रूप से, यह अजवाइन नौकरियों को बचाने के लिए बैकेंड के रूप में Django ORM का उपयोग करता है, और यह स्वचालित रूप से INSTALLED_APPS में सूचीबद्ध Django अनुप्रयोगों के लिए अजवाइन नौकरियों को ढूंढता है और लॉग करता है।

Django-celery स्थापित करने के बाद, आपको कॉन्फ़िगर करने की आवश्यकता है:

• djcelery को INSTALLED_APPS सूची में जोड़ें:
  

   INSTALLED_APPS += ("djcelery", ) 

  
  
• निम्नलिखित पंक्तियों को django सेटिंग्स फ़ाइल में जोड़ें {{settings.py}}:
  

   import djcelery djcelery.setup_loader() 

  
  
• डेटाबेस में आवश्यक तालिकाएँ बनाएँ:
  

   ./manage.py syncdb 

  
  
• हम डेटाबेस को आवधिक कार्यों के लिए भंडारण स्थान के रूप में सेट करते हैं, इसे सेटिंग्स में जोड़ें:
  

   CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler" 

  
  इस विकल्प के साथ, हम django admin पैनल के माध्यम से आवधिक नौकरियों को जोड़ / हटा / संपादित कर सकेंगे।
  

Mod_wsgi का उपयोग करते समय, WSGI कॉन्फ़िगरेशन फ़ाइल में निम्न पंक्तियाँ जोड़ें:

 import os os.environ["CELERY_LOADER"] = "django" 

Django-कोम्बु

अब हमें बस सेलेरी के लिए एक उपयुक्त संदेश ब्रोकर ढूंढना होगा, इस लेख में मैं django-kombu - एक पैकेज का उपयोग करूंगा जो आपको Kombu के लिए संदेश स्टोर (अजगर में एएमपीक्यू कार्यान्वयन) के रूप में Django डेटाबेस का उपयोग करने की अनुमति देता है।
पैकेज स्थापित करें:

 easy_install django-kombu 

सेट करें:

• djkombu को INSTALLED_APPS सूची में जोड़ें:
  

   INSTALLED_APPS += ("djkombu", ) 

  
  
• Djkombu को सेटिंग्स में दलाल के रूप में सेट करें:
  

   BROKER_BACKEND = "djkombu.transport.DatabaseTransport" 

  
  
• हम डेटाबेस में आवश्यक तालिकाएँ बनाते हैं:
  

   ./manage.py syncdb 

हम लॉन्च करते हैं

हम अजवाइन और अजवाइन की प्रक्रिया शुरू करते हैं:
(अजवाइन के बिना, आप नियमित कार्यों को शुरू और कर सकते हैं। अनुसूचित अनुसूचित कार्यों के लिए सेलेरबीट चलाने की आवश्यकता है)

• लिनक्स में, दोनों प्रक्रियाओं को एक साथ -B स्विच के साथ शुरू किया जा सकता है:
  

   # ./manage.py celeryd -B -------------- celery@test v2.2.7 ---- **** ----- --- * *** * -- [Configuration] -- * - **** --- . broker: djkombu.transport.DatabaseTransport://guest@localhost0/ - ** ---------- . loader: djcelery.loaders.DjangoLoader - ** ---------- . logfile: [stderr]@WARNING - ** ---------- . concurrency: 16 - ** ---------- . events: OFF - *** --- * --- . beat: ON -- ******* ---- --- ***** ----- [Queues] -------------- . celery: exchange:celery (direct) binding:celery 

  
  
• खिड़कियों पर, अजवाइन और अजवाइन को अलग-अलग चलाया जाना चाहिए:
  

   ./manage.py celeryd --settings=settings ./manage.py celerybeat 

  
  निम्न अपवाद होने पर --settings विकल्प की आवश्यकता हो सकती है:
  

   ImportError: Could not import settings 'app_name.settings' (Is it on sys.path?): No module named app_name.settings 

  
  समस्या के बारे में अधिक जानकारी: http://groups.google.com/group/celery-users/browse_thread/thread/43a95be6865a636/d91ab2492885f3d4?lnk=gn&q=settings#d91ab2492885f3d4d4
  विंडोज पर अजवाइन के साथ ज्ञात मुद्दों की पूरी सूची: http://celeryproject.org/docs/faq.html#windows
  

शुरू करने के बाद, हम देख सकते हैं कि django व्यवस्थापक पैनल में आवधिक कार्य कैसे दिखते हैं:



यदि आप अजवाइन बैकेंड के रूप में Django ORM (उदाहरण के लिए RabbitMQ) के अलावा कुछ का उपयोग करते हैं, तो Django व्यवस्थापक पैनल में आप अन्य सभी कार्यों की स्थिति भी देख सकते हैं, यह कुछ इस तरह दिखता है:


अधिक जानकारी: http://stackoverflow.com/questions/5449163/django-celery-admin-interface-showing-zero-tasks-workers

अद्यतन: मैं पहले से काम नहीं कर सकता, क्योंकि मैं डीमनाइजेशन के बारे में थोड़ा जोड़ रहा हूं ।

एक सेवा के रूप में अजवाइन चलाएँ

यहाँ से अजवाइन लॉन्च स्क्रिप्ट डाउनलोड करें: https://github.com/ask/celery/tree/master/contrib/generic-init.d/ और इसे उपयुक्त अधिकारों के साथ /etc/init.d निर्देशिका में रखें।
/ Etc / डिफ़ॉल्ट निर्देशिका में , celeryd फ़ाइल बनाएं, जिसमें से स्क्रिप्ट स्टार्टअप सेटिंग्स को ले जाएगी:

 # Where the Django project is. CELERYD_CHDIR="/var/www/myproject" # Path to celeryd CELERYD_MULTI="$CELERYD_CHDIR/manage.py celeryd_multi" CELERYD_OPTS="--time-limit=300 --concurrency=8 -B" CELERYD_LOG_FILE=/var/log/celery/%n.log # Path to celerybeat CELERYBEAT="$CELERYD_CHDIR/manage.py celerybeat" CELERYBEAT_LOG_FILE="/var/log/celery/beat.log" CELERYBEAT_PID_FILE="/var/run/celery/beat.pid" CELERY_CONFIG_MODULE="settings" export DJANGO_SETTINGS_MODULE="settings" 

--Concurrency विकल्प अजवाइन प्रक्रियाओं की संख्या निर्धारित करता है (डिफ़ॉल्ट रूप से, यह संख्या प्रोसेसर की संख्या के बराबर है)।
उसके बाद, आप सेवा का उपयोग करके अजवाइन शुरू कर सकते हैं:

 service celeryd start 

अधिक जानकारी: docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing

अजवाइन के साथ काम करें

Django-celery को स्थापित करने के बाद, INSTALLED_APPS में सूचीबद्ध सभी अनुप्रयोगों से अजवाइन की नौकरियों को स्वचालित रूप से सभी कार्यक्षेत्र मॉड्यूल से पंजीकृत किया जाता है । कार्य मॉड्यूल के अलावा, आप CELERY_IMPORTS पैरामीटर का उपयोग करके अतिरिक्त मॉड्यूल भी निर्दिष्ट कर सकते हैं:

 CELERY_IMPORTS=('myapp.my_task_module',) 

यह CELERY_SEND_TASK_ERROR_EM Colors विकल्प को सक्रिय करने के लिए भी उपयोगी है, धन्यवाद जिसके कारण सेलेरी ADMINS चर में सूचीबद्ध पते की सभी त्रुटियों को सूचित करेगी।

पिछले लेख के बाद से अजवाइन के लिए लेखन कार्य बहुत नहीं बदले हैं:

 from celery.task import periodic_task from celery.schedules import crontab @periodic_task(ignore_result=True, run_every=crontab(hour=0, minute=0)) def clean_sessions(): Session.objects.filter(expire_date__lt=datetime.now()).delete() 

अंतर केवल इतना है कि डेकोरेटर्स को अब सेलेरी.टैस्क से आयात किया जाना चाहिए, डेकोरेटर्स मॉड्यूल अपग्रेड हो गए हैं।

प्रदर्शन नोटों की एक जोड़ी:

• यदि कार्य कोई परिणाम नहीं देता है, तो ign_result = True विकल्प सेट करना बेहतर है
• यदि आपके कार्य उनका उपयोग नहीं करते हैं तो दर सीमाएँ बंद करें:
  

   CELERY_DISABLE_RATE_LIMITS = True 

इन और अन्य अजवाइन युक्तियों के बारे में और अधिक: http://celeryproject.org/docs/userguide/tasks.html#tips-and-best-practices