twitter stream consumer

streamConsumer.py

import tweepy
from tweepy import auth

CONSUMER_KEY="" #FIXME
CONSUMER_SECRET="" #FIXME 
TOKEN_KEY="" #FIXME
TOKEN_SECRET="" #FIXME


#override tweepy.StreamListener to add logic to on_status
class MyStreamListener(tweepy.StreamListener):
    def on_status(self, status):
        print(status.text.encode('utf8'))


auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
auth.set_access_token(TOKEN_KEY, TOKEN_SECRET)
api = tweepy.API(auth)

myStream = tweepy.Stream(auth = api.auth, listener=MyStreamListener())

myStream.filter(track=["RIPLKY", "RememberingLKY", "LKY", "RememberingLeeKuanYew"], async=True)