なぜこのエラーが発生しますか?ここで私はストリーミングAPIをどのように呼びます。おそらく、GAEによって引き起こさTwitterでストリーミングする
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))
ソケットを許可されていない、私は特定のフィルタストリーミングツイートを取得するには、クエリ用語を適用するかどうかはわかりません。このコード部分の私の目的は、指定されたキーワードでライブストリームを取得することです。代替方法がある場合は、ご案内ください。
一部の人は、GoogleがGAEでソケットを使用することを許可していないと述べていますが、他にも例がありますので参考にしてください。ありがとう – 1myb