नमस्कार, हेब्र! मैं आपको अपने पेशेवर बर्नआउट की कहानी बताऊंगा।

ऐसा हुआ कि मुझे रूटीन ट्रेडमिल से नफरत है। मेरे पास सेलेरी का उपयोग करने वाली कई परियोजनाएं हैं। हर बार जब कोई कार्य 2 + 2 = 5 से अधिक जटिल हो जाता है, तो समाधान टेम्पलेट एक वर्ग बनाने के लिए कम हो जाता है जो कार्य करता है, और एक स्टार्टर फ़ंक्शन जो सेलेरी के साथ काम करने में सक्षम है - एक बॉयलरप्लेट। इस लेख में मैं आपको बताऊंगा कि कैसे मैंने एक बॉयलरप्लेट के साथ संघर्ष किया और इसके बारे में क्या आया।

प्रारंभिक बिंदु

अजवाइन के साधारण कार्य पर विचार करें। एक वर्ग है जो कार्य करता है, और एक स्टार्टर फ़ंक्शन, जो कक्षा को तत्काल तैयार करता है और इसके तरीकों में से एक शुरू करता है, जिसमें कार्य के सभी तर्क को लागू किया जाता है और त्रुटि हैंडलिंग विरासत में मिली है:

 class MyTask( FirstMixin, SecondMixin, ThirdMixin, ): def main(self): data = self.do_something() response = self.remote_call(data) parsed = self.parser(response) return self.process(parsed) @app.task(bind=True) def my_task(self, arg1, arg2): instance = MyTask( celery_task=self, arg1=arg1, arg2=arg2, ) return instance.full_task() 

उसी समय, full_task पद्धति में main लिए कॉल शामिल है, हालांकि, यह त्रुटि से निपटने, लॉगिंग और अन्य बकवास से भी संबंधित है जो सीधे मुख्य कार्य से संबंधित नहीं है।

टास्कक्लास विचार

टास्कक्लास की जड़ में एक सरल विचार निहित है: बेस क्लास में, आप task क्लास की एक विधि को परिभाषित कर सकते हैं, इसमें स्टार्टर फ़ंक्शन के व्यवहार को लागू कर सकते हैं, और फिर वारिस कर सकते हैं:

 class BaseTask: def __init__(self, **kwargs): for key, value in kwargs.items(): setattr(self, key, value) def full_task(self): try: return self.main() except: self.celery_task.retry(countdown=30) @classmethod def task(cls, task, **kwargs): self = cls( celery_task=celery_task, **kwargs, ) return self.full_task() 

बेस क्लास में एकत्रित सभी सहायक बोरियत। हम फिर उसके पास नहीं लौटेंगे। हमें कार्य के तर्क का एहसास है:

 @app.taskcls(bind=True) class MyTask( BaseTask, FirstMixin, SecondMixin, ThirdMixin, ): def main(self): data = self.do_something() response = self.remote_call(data) parsed = self.parser(response) return self.process(parsed) 

ज्यादा भूसी नहीं, ज्यादा बेहतर। हालांकि, प्रवेश बिंदु के बारे में क्या?

 MyTask.task.delay(...) 

MyTask.task में सभी सामान्य कार्य विधियाँ हैं: delay , apply_async और, आम तौर पर बोलना, यह है।

अब डेकोरेटर के तर्क। प्रत्येक कार्य में bind = True को ड्रैग करना विशेष रूप से मजेदार है। क्या आधार वर्ग के माध्यम से डिफ़ॉल्ट तर्क पारित करना संभव है?

 class BaseTask: class MetaTask: bind = True def __init__(self, **kwargs): for key, value in kwargs.items(): setattr(self, key, value) def full_task(self): try: return self.main() except: self.celery_task.retry(countdown=30) @classmethod def task(cls, task, **kwargs): self = cls( celery_task=celery_task, **kwargs, ) return self.full_task() 

नेस्टेड MetaTask क्लास में डिफ़ॉल्ट तर्क होते हैं और यह सभी बाल वर्गों के लिए उपलब्ध होगा। दिलचस्प है, यह विरासत में भी मिल सकता है:

 class BaseHasTimeout(BaseTask): class MetaTask(BaseTask.MetaTask): timeout = 42 

@app.taskcls डेकोरेटर को @app.taskcls गए तर्क सर्वोच्च प्राथमिकता है:

 @app.taskcls(timeout=20) class MyTask( BaseHasTimeout, FirstMixin, SecondMixin, ThirdMixin, ): def main(self): ... 

नतीजतन, कार्य के लिए समय सीमा 20 हो जाएगी।

परे जा रहे हैं

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

 class BaseViewTask: @classmethod def task(cls, **kwargs): # Somehow init View class manually self = cls(...) return self.celery() @app.taskcls class MyView( BaseViewTask, FirstMixin, SecondMixin, ThirdMixin, APIView, ): queryset = MyModel.objects.all() def get_some_data(self, *args, **kwargs): # common methed return self.queryset.filtert(...) def get(self, request): data = self.get_some_data(request.field) # used in request handling return Response(json.dumps(data)) def post(self, request): self.task.delay(...) return Response(status=201) def celery(self): data = self.get_some_data(...) # also used in background task return self.do_something(data) 

वैसे, नामों की टकराहट से बचने के लिए, नेस्टेड क्लास को MetaTask कहा जाता है, Meta नहीं, जैसा कि MetaTask में।

निष्कर्ष

सेलेरी 4.5 में यह कार्यक्षमता अपेक्षित है। हालाँकि, मैंने एक पैकेज भी तैयार किया है जिससे आप आज टास्कक्ल्स डेकोरेटर को आज़मा सकते हैं। पैकेज का विचार यह है कि जब आप सेलेरी को संस्करण 4.5 में अपग्रेड करते हैं, तो आप कोड की एक पंक्ति को बदले बिना इसके आयात को हटा सकते हैं।