Guest User

Untitled

a guest
Jan 25th, 2018
74
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.84 KB | None | 0 0
  1. import djcelery
  2. djcelery.setup_loader()
  3.  
  4. import redis
  5. import tweepy
  6.  
  7. from twitpop.tasks import score_tweet
  8.  
  9. db = redis.Redis(host='localhost', port=6379, db=0)
  10.  
  11. class StreamWatcherListener(tweepy.StreamListener):
  12.  
  13. def on_status(self, status):
  14. try:
  15. score_tweet.delay(status.text)
  16. except Exception as exception:
  17. pass
  18.  
  19. def on_error(self, status_code):
  20. return True # keep stream alive
  21.  
  22. def on_timeout(self):
  23. pass
  24.  
  25.  
  26. def main():
  27. username = db.get("twitter:username")
  28. password = db.get("twitter:password")
  29. stream = tweepy.Stream(username, password, StreamWatcherListener(), timeout=None)
  30.  
  31. track_list = db.zrange("twitter:search", 0, -1)
  32. stream.filter([], track_list)
  33.  
  34.  
  35. if __name__ == '__main__':
  36. try:
  37. main()
  38. except KeyboardInterrupt:
  39. print '\nGoodbye!'
Add Comment
Please, Sign In to add comment