X-Git-Url: https://projects.mako.cc/source/twitter-api-cdsw-solutions/blobdiff_plain/5f84907a072eb4dd4b58dce2634f24ede6181eb8..d4653b5f599083dc7631ff1a215096ac58b626d8:/twitter-stream-raw1.py diff --git a/twitter-stream-raw1.py b/twitter-stream-raw1.py deleted file mode 100644 index 734a59f..0000000 --- a/twitter-stream-raw1.py +++ /dev/null @@ -1,30 +0,0 @@ -import json -import tweepy -from twitter_authentication import CONSUMER_KEY, CONSUMER_SECRET, ACCESS_TOKEN, ACCESS_TOKEN_SECRET - -auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET) -auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET) - -api = tweepy.API(auth, parser=tweepy.parsers.RawParser) - -@classmethod -def parse(cls, api, raw): - status = cls.first_parse(api, raw) - setattr(status, 'json', json.dumps(raw)) - return status - -tweepy.models.Status.first_parse = tweepy.models.Status.parse -tweepy.models.Status.parse = parse - -class StreamListener(tweepy.StreamListener): - def on_status(self, tweet): - print tweet.json - - def on_error(self, status_code): - print 'Error: ' + repr(status_code) - return False - -l = StreamListener() -streamer = tweepy.Stream(auth=auth, listener=l) - -streamer.sample()