Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from tweepy import Stream
- from tweepy import OAuthHandler
- from tweepy.streaming import StreamListener
- import time
- ckey = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
- csecret = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
- atoken = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
- asecret = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
- class listener(StreamListener):
- def on_data(self, data):
- try:
- # print data
- tweet = data.split(',"text":"')[1].split('","source')[0]
- print tweet
- saveThis = str(time.time())+'::'+tweet
- saveFile = open('twitDB2.csv','a')
- saveFile.write(saveThis)
- saveFile.write('\n')
- saveFile.close()
- return True
- except BaseException, e:
- print 'failed ondata,',str(e)
- time.sleep(5)
- def on_error(self, status):
- print status
- auth = OAuthHandler(ckey, csecret)
- auth.set_access_token(atoken, asecret)
- twitterStream = Stream(auth, listener())
- twitterStream.filter(track=["the division"])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement