python
import rainbowstream
from rainbowstream.rainbowcore import RainbowCore
class RainbowStreamer(RainbowCore):
def __init__(self):
super(RainbowStreamer, self).__init__()
def on_new_tweets(self, tweet):
def on_new_direct_message(self, message):
def on_status(self, status):
def on_event(self, event):
def on_delete(self, tweet_id):
def on_error(self, error):
if __name__ == "__main__":
rainbow_streamer = RainbowStreamer()
rainbow_streamer.run()
python
from rainbowstream.rainbowlib import RainbowLoggingHandler
def configure_rainbow_streamer():
rainbow_logging_handler = RainbowLoggingHandler()
rainbow_logging_handler.setFormatter(logging.Formatter(
'%(asctime)s - %(levelname)s - %(message)s'))
logger = logging.getLogger()
logger.addHandler(rainbow_logging_handler)
logger.setLevel(logging.INFO)
conf = {
"TWITTER_CONSUMER_KEY": "your_consumer_key",
"TWITTER_CONSUMER_SECRET": "your_consumer_secret",
"TWITTER_ACCESS_TOKEN": "your_access_token",
"TWITTER_ACCESS_TOKEN_SECRET": "your_access_token_secret"
}
streamer = RainbowStreamer()
streamer.load_config(conf)
if __name__ == "__main__":
configure_rainbow_streamer()
