Twitter Streaming na GAE

Question

Dlaczego otrzymuję ten błąd? i oto jak nazywam streaming API.

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)) 

Prawdopodobnie przyczyną przez GAE nie wolno gniazdo, nie jestem pewien, jak zastosować termin zapytania, aby uzyskać konkretne filtrowane tweets strumieniowych. Moim celem w tej części kodu jest uzyskanie transmisji na żywo za pomocą oznaczonych słów kluczowych. Jeśli istnieją jakieś alternatywne metody, prosimy o przypomnienie.

Answer 1

w App Engine, httplib połączenia (i urllib) używa Google URL pobrać usługę. URL Fetch service oznacza, że ​​inne serwery (a nie instancja obsługująca mechanizm aplikacji) wykonują żądanie i zwracają odpowiedź do instancji mechanizmu aplikacji, zamiast do samego procesu otwierania gniazda.

Wydaje mi się, że zauważyłeś, że wariant httplib działający na GAE nie zapewnia atrybutu skarpet używanego do ustawiania limitu czasu. Podstawowym problemem jest jednak to, że nie ma sposobu, aby uzyskać strumień, nie otrzymasz żadnych wyników z powrotem do silnika aplikacji, dopóki odpowiedź nie zostanie zakończona. Nie testowałem, jak to się nie powiedzie, ale spodziewam się, że otrzymasz Deadline ExceedError z usługi URL, ponieważ Twitter nie zamknie odpowiedzi strumieniowej.

W tej chwili nie ma alternatywnych metod uzyskiwania strumienia na GAE. Może działać z obsługą gniazd wychodzących na zapleczu. Obsługa gniazd jest obecnie dostępna tylko dla testerów.

Answer 2

Uważam, że GAE nie obsługuje protokołu httplib.HTTPSConnection. Zamiast tego, spróbuj niezabezpieczonych połączeń przez dodanie parametru secure = False do konstruktora Stream:

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))