X-Git-Url: https://projects.mako.cc/source/twitter-api-cdsw-solutions/blobdiff_plain/1e2d406ccc7bfaa9c73ab809367ce5ae2ab6fc79..d4653b5f599083dc7631ff1a215096ac58b626d8:/twitter-stream-raw1.py diff --git a/twitter-stream-raw1.py b/twitter-stream-raw1.py deleted file mode 100644 index b6ea13b..0000000 --- a/twitter-stream-raw1.py +++ /dev/null @@ -1,31 +0,0 @@ -import encoding_fix -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()