GAE पर ट्विटर स्ट्रीमिंग

Question

मुझे यह त्रुटि क्यों मिल रही है? और यहां मैं स्ट्रीमिंग एपीआई को कैसे कॉल करता हूं।

import tweepy 
import sys 

creds = json.loads(open('credential.json').read()) 
tw_consumer_key = creds['tw_consumer_key'] 
tw_consumer_secret = creds['tw_consumer_secret'] 
tw_access_token = creds['tw_access_token'] 
tw_access_token_secret = creds['tw_access_token_secret'] 

try: 
    auth = tweepy.OAuthHandler(tw_consumer_key, tw_consumer_secret) 
    auth.set_access_token(tw_access_token, tw_access_token_secret) 
    api = tweepy.API(auth) 
except Exception: 
    service = None 
    api = None  

# Query terms 
Q = "Better" 

class CustomStreamListener(tweepy.StreamListener): 
    def on_status(self, status): 
     try: 
      print "%s\n%s\n%s\n%s\n\n" % (status.text, 
             status.author.screen_name, 
             status.created_at, 
             status.source,) 
     except Exception, e: 
      print >> sys.stderr, 'Encountered Exception:', e 
      pass 

    def on_error(self, status_code): 
     print >> sys.stderr, 'Encountered error with status code:', status_code 
     return True # Don't kill the stream 

    def on_timeout(self): 
     print >> sys.stderr, 'Timeout...' 
     return True # Don't kill the stream 



class LiveStream(webapp2.RequestHandler): 
    def get(self): 
     streaming_api = tweepy.streaming.Stream(auth, CustomStreamListener(), timeout=60) 
     self.response.out.write(streaming_api.filter(track=Q)) 

शायद GAE द्वारा कारण सॉकेट अनुमति नहीं है, मुझे यकीन है कि कैसे क्वेरी शब्द लागू करने के लिए विशिष्ट फ़िल्टर्ड स्ट्रीमिंग ट्वीट्स पाने के लिए नहीं कर रहा हूँ। कोड के इस हिस्से के साथ मेरा उद्देश्य नामित कीवर्ड के साथ लाइव स्ट्रीम प्राप्त करना है। यदि कोई वैकल्पिक तरीका है, तो कृपया गाइड करें।

Answer 1

App इंजन पर, httplib कनेक्शन (और urllib) गूगल URL को प्राप्त सेवा का उपयोग करेगा: इसके बजाय, Stream निर्माता को secure = False पैरामीटर जोड़कर एक असुरक्षित कनेक्शन का प्रयास करें। URL Fetch service का मतलब है अन्य सर्वर (ऐप इंजन सेवारत उदाहरण नहीं) अनुरोध करते हैं और ऐप इंजन इंस्टेंस को प्रतिक्रिया वापस लौटाते हैं, प्रक्रिया के बजाए एक सॉकेट खोलने के बजाय।

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

इस समय GAE पर स्ट्रीम प्राप्त करने के लिए कोई वैकल्पिक तरीका नहीं है। यह बैकएंड पर आउटबाउंड सॉकेट समर्थन के साथ काम कर सकता है। सॉकेट समर्थन वर्तमान में केवल परीक्षकों के लिए उपलब्ध है।

Answer 2

मेरा मानना ​​है कि जीएई fansplib.HTTPSConnection का समर्थन नहीं करता है।

class LiveStream(webapp2.RequestHandler): 
    def get(self): 
     streaming_api = tweepy.streaming.Stream(auth, CustomStreamListener(), timeout=60, secure=False) 
     self.response.out.write(streaming_api.filter(track=Q))