Advertisement
Guest User

Untitled

a guest
Jan 31st, 2015
200
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.07 KB | None | 0 0
  1. #!/usr/bin/python -u
  2. #-*- coding: utf-8 -*-
  3. import tweepy, json, pymongo
  4.  
  5. #Autenticazione
  6. from keys import keys
  7.  
  8. SCREEN_NAME = keys['screen_name']
  9. CONSUMER_KEY = keys['consumer_key']
  10. CONSUMER_SECRET = keys['consumer_secret']
  11. ACCESS_TOKEN = keys['access_token']
  12. ACCESS_TOKEN_SECRET = keys['access_token_secret']
  13.  
  14. auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
  15. auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)
  16.  
  17. api = tweepy.API(auth)
  18.  
  19. class CustomStreamListener(tweepy.StreamListener):
  20. def __init__(self, api):
  21. self.api = api
  22. super(tweepy.StreamListener, self).__init__()
  23.  
  24. self.db = pymongo.MongoClient().test
  25.  
  26. def on_data(self, tweet):
  27. self.db.europe.insert(json.loads(tweet))
  28.  
  29. def on_error(self, status_code):
  30. return True # Don't kill the stream
  31.  
  32. def on_timeout(self):
  33. return True # Don't kill the stream
  34.  
  35.  
  36. sapi = tweepy.streaming.Stream(auth, CustomStreamListener(api))
  37. #sapi.filter(track=['#Apple', '#Linux', '#Windows'])
  38. sapi.filter(locations=[-122.75,36.8,-121.75,37.8])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement