एक Django आवेदन में अजवाइन का उपयोग करने के लिए 3 मामले

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

अजवाइन कार्य कतार के प्रबंधन के लिए एक प्रणाली है। मौलिक रूप से सक्षम 2 चीजें: कतार से कार्यों को लें और एक कार्यक्रम पर कार्य करें। कतार ब्रोकर आमतौर पर RabbitMQ या Redis है। कार्यों को कतार में रखा जाता है, और फिर सेलेरी कार्यकर्ता उन्हें वहां से ले जाते हैं और उनका प्रदर्शन करते हैं।

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

1. अनुसूचित कार्य

अक्सर ऐसे कार्य होते हैं जिन्हें एक विशिष्ट तिथि और समय पर पूरा करने की आवश्यकता होती है: उपयोगकर्ता को एक अनुस्मारक भेजें, खाते की परीक्षण अवधि समाप्त करें, सोशल नेटवर्क पर एक पोस्ट प्रकाशित करें।

सेलेरी में, कार्य को कॉल करते समय ईटीए पैरामीटर निर्दिष्ट करना संभव है - जिस समय कार्य को लॉन्च किया जाना चाहिए। लेकिन अगर आप इस तरह से कार्यों की योजना बनाते हैं, तो यह बहुत अविश्वसनीय हो जाता है: वे शुरू नहीं हो सकते हैं और वे रद्द करने के लिए असहज हो सकते हैं।

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

# schedule.py from datetime import timedelta from celery.schedules import crontab CELERYBEAT_SCHEDULE = { 'publish_post_starter': { 'task': 'publish_post_starter', 'schedule': timedelta(minutes=1), }, 'end_trial_starter': { 'task': 'end_trial_starter', 'schedule': crontab(hour=10, minute=21), }, } 

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

 # tasks.py @app.task(name='publish_post') def publish_post(post_id): ... @app.task(name='publish_post_starter') def publish_post_starter(): post_ids = list( Post.objects.filter( publish_dt__lte=timezone.now(), is_published=False ).values_list('id', flat=True) ) for post_id in post_ids: publish_post.delay(post_id) 

2. लॉन्ग कंप्यूटिंग और एपीआई WSGI से कॉल करता है

WSGI उस संदर्भ को संदर्भित करता है जिसमें उपयोगकर्ताओं से अनुरोध संसाधित किए जाते हैं (अनुरोध-प्रतिक्रिया चक्र)। अतुल्यकालिक कार्यों के संदर्भ में - अजवाइन।

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

WSGI में, हम कार्य को कॉल करते हैं और प्रतिक्रिया देते हैं। सामने की ओर, बटन को अनलॉक करें और स्पिनर को हटा दें। हम उपयोगकर्ता को एक संदेश दिखाते हैं कि कार्रवाई चल रही है। समानांतर में, एक सेलेरी कार्य निष्पादित किया जाता है, जो पूरा होने पर, वेब सॉकेट पर एक प्रतिक्रिया देता है। सामने वाले पर परिणाम प्राप्त करने के बाद, हम इसे उपयोगकर्ता को दिखाते हैं।

 # rest_views.py from rest_framework import status from rest_framework.views import APIView from rest_framework.response import Response from tasks import send_emails class SendEmailView(APIView): def post(self, request): # this id will be used to send response with websocket request_uuid = request.data.get('request_uuid') if not request_uuid: return Response(status=status.HTTP_400_BAD_REQUEST) send_emails.delay(request.user.id, request_uuid) return Response(status=status.HTTP_200_OK) 

अलग-अलग, आप WSGI से बाहरी API कॉल को अलग कर सकते हैं। इस मामले में, सभी कॉल, उनके निष्पादन की अवधि की परवाह किए बिना, सेलेरी कार्य के माध्यम से लॉन्च किए जाते हैं। यह मूर्ख से सुरक्षा है। ऐसी स्थिति नहीं होनी चाहिए, जहां कुछ बाहरी एपीआई की दुर्गमता के कारण, उपयोगकर्ता इंटरफ़ेस जमा करता है।

3. बवंडर से चुनौती

सोशल नेटवर्क, टेलीग्राम या भुगतान सेवा के साथ एकीकरण करते समय, आपको एक webhook url की आवश्यकता होती है, जिसमें सूचनाएं आएंगी। अनुरोधों की संख्या हमेशा अग्रिम में गणना नहीं की जा सकती है, लेकिन सबसे अधिक संभावना है कि उनकी संख्या उपयोगकर्ताओं से अनुरोधों को पार करेगी। ये अनुरोध तब तक प्राप्त किए जाएंगे, जब तक उन्हें कोड 200 के साथ प्रतिक्रिया नहीं मिल जाती।

ऐसे अनुरोधों को संसाधित करने के लिए, बवंडर असिंक्रोनस फ्रेमवर्क उपयुक्त है। प्रसंस्करण को टर्नैडो में सिंक्रोनस में नहीं बदलने के लिए कोई अवरोधक संचालन नहीं होना चाहिए। यह वह जगह है जहां अजवाइन की जरूरत है। बवंडर हैंडलर अनुरोध प्राप्त करता है, डेटा को मान्य करता है, सेलेरी कार्य को कॉल करता है, और एक सफल प्रतिक्रिया देता है।

 # tornado_handlers.py from tornado import gen, escape from tornado.web import RequestHandler from tasks import handle_vk_callback class VkCallbackHandler(RequestHandler): @gen.coroutine def post(self, *args, **kwargs): try: data = escape.json_decode(self.request.body) except ValueError: self.set_status(status_code=400, reason='Invalid data') return handle_vk_callback.delay(data) self.write('ok') return