Asyncmongo के लिए बवंडर सर्वर में इनलाइन-कॉलबैक

कुछ हफ़्ते पहले, टोरनेडो डेवलपर्स ने इनलाइन कॉलबैक बनाने के लिए एक देशी मॉड्यूल जोड़ा (ट्विन्ट में इनलाइन कॉलबैक का एक एनालॉग, नोड में सीक, जेबी, रूबी में फाइबर)।
नीचे asyncmongo (mongoDB के लिए अतुल्यकालिक चालक) से जुड़े उदाहरण और उदाहरण दिए गए हैं

तुलना के लिए, मैं कैलबेक के साथ एक क्लासिक उदाहरण दूंगा

class AsyncHandler(RequestHandler): @asynchronous def get(self): http_client = AsyncHTTPClient() http_client.fetch("http://example.com", callback=self.on_fetch) def on_fetch(self, response): do_something_with_response(response) self.render("template.html") 

और इसलिए, नए मॉड्यूल "tornado.gen" के साथ

  class GenAsyncHandler(RequestHandler): @asynchronous @gen.engine def get(self): http_client = AsyncHTTPClient() response = yield gen.Task(http_client.fetch, "http://example.com") do_something_with_response(response) self.render("template.html") 

मुड़ के समान जनरेटर के माध्यम से कॉल किए जाते हैं।

आप तरीकों की एक सरणी भी कह सकते हैं, जब सभी निर्दिष्ट तरीकों से काम किया जाता है, तो नियंत्रण रिटर्न

  def get(self): http_client = AsyncHTTPClient() response1, response2 = yield [gen.Task(http_client.fetch, url1), gen.Task(http_client.fetch, url2)] 

उन्होंने अलग-अलग समय पर लॉन्च किए गए सभी आवश्यक तरीकों के पूरा होने की प्रतीक्षा करने के लिए एक सुविधाजनक तंत्र (कॉलबैक और प्रतीक्षा विधियों) को भी जोड़ा।

  class GenAsyncHandler2(RequestHandler): @asynchronous @gen.engine def get(self): http_client = AsyncHTTPClient() http_client.fetch("http://example.com", callback=(yield gen.Callback("key")) response = yield gen.Wait("key") do_something_with_response(response) self.render("template.html") 

उपरोक्त सभी उदाहरण बवंडर मॉड्यूल से लिया गया था

कैसे asyncmongo के साथ इसका उपयोग करने का एक उदाहरण

 class MainHandler(tornado.web.RequestHandler): @property def db(self): if not hasattr(self, '_db'): self._db = asyncmongo.Client(pool_id='mydb', host='127.0.0.1', \ port=27017, maxcached=10, maxconnections=50, dbname='test') return self._db @web.asynchronous @gen.engine def get(self): r, error = yield gen.Task(self.db.user.save, { 'login':'tester' }) r, error = yield gen.Task(self.db.user.find_one, {}) self.write(str(r[0])) self.finish() 

यहां, परिणाम प्राप्त करने के लिए सेव और फाइंड_ऑन विधियों को बदले में बुलाया जाता है।

निम्नलिखित उदाहरण के लिए, मैंने एक बैसाखी-आवरण बनाया, ताकि मोंगोडब का उपयोग क्लासिक की तरह हो (db.user.save ({'login': 'tester'}), db.user.find_one ({}))

 class MainHandler(tornado.web.RequestHandler): @property def db(self): if not hasattr(self, '_db'): self._db = tornadomongo.mongo_client(pool_id='mydb', host='127.0.0.1', port=27017, maxcached=10, maxconnections=50, dbname='test') return self._db @web.asynchronous @gen.engine def get(self): # save r = yield self.db.user.save({ 'login':'tester' }) # find try: r = yield self.db.user.find_one({}) self.write(str(r)) except tornadomongo.MongoError as e: self.write('error: '+str(e)) self.finish() 

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

कौन प्रयास करना चाहता है, टॉर्नाडोमोंगो मॉड्यूल यहाँ है: hg क्लोन bitbucket.org/lega911/tornadomongo
इसमें, मुझे बवंडर मॉड्यूल में एक "गंदा इंजेक्शन" बनाना था, ताकि एक अपवाद बनाने में सक्षम हो, जो इस मॉड्यूल को केवल प्रयोगों के लिए उपयोग करने की अनुमति देता है।

मैंने पहले ही एक प्रोजेक्ट के कुछ मॉड्यूल्स को tornado.gen में ट्रांसलेट कर दिया, नतीजतन, कोड की मात्रा कम हो गई, कोड की पठनीयता बढ़ गई (उसी कार्यक्षमता की)।

पुनश्च: लेखन के समय, मॉड्यूल को दस्तावेज में वर्णित नहीं किया गया था, अब पोस्ट किया गया: www.tornadoweb.org/documentation/gen.html