अतुल्यकालिक आरपीसी

हालांकि, मैं अतुल्यकालिक अनुरोधों के समर्थन के साथ डेटास्टोर के साथ काम करने के लिए एक नए ग्राहक पुस्तकालय के लिए नींव रख रहा हूं, मैंने कुछ निम्न-स्तरीय कार्यक्षमता जोड़ी जो आप आज उपयोग कर सकते हैं। अतुल्यकालिक अनुरोधों के लिए प्रलेखित समर्थन के साथ एकमात्र एपीआई है urlfetch । और यह कार्यक्षमता काफी उपयोगी हो सकती है।

मान लें कि हमें किसी दूरस्थ सेवा से कुछ डेटा का चयन करने की आवश्यकता है। सेवा के 2 उदाहरण हैं, जिनमें से दोनों थोड़ा भरी हुई हैं। हम जो करना चाहते हैं, दोनों सेवाओं को एक ही समय में अनुरोध भेजना है (यह आसान हिस्सा है), और फिर उनमें से एक से परिणाम की प्रतीक्षा करें।

from google.appengine.api import urlfetch, apiproxy_stub_map urls = ['http://service1.com', 'http://service2.com'] # Etc. rpcs = [] for url in urls: rpc = urlfetch.create_rpc(deadline=1.0) urlfetch.make_fetch_call(rpc, url) rpcs.append(rpc) rpc = apiproxy_stub_map.UserRPC.wait_any(rpcs) # Now rpc is the first rpc that returned a result. Have at it! 

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

अगली प्रतिक्रिया प्राप्त करने के लिए आप बार-बार Wait_any () भी कॉल कर सकते हैं। सूची से पूर्ण अनुरोध को हटाना सुनिश्चित करें: Wait_any () विनिर्देश आपको बताता है कि पहले पूरा अनुरोध सूची से वापस आ गया है, भले ही आपने इसे देखा हो या नहीं।

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

अंत में, एक अन्य समान UserRPC.wait_all () विधि है जो सभी अनुरोधों को पूरा करने की उम्मीद करती है (यह कुछ भी नहीं लौटाता है)।