foo.twitter_stream.py

import yaml
import twitter

def get_tweet():
    with open("config.yaml") as f:
        config = yaml.load(f)

    stream = twitter.TwitterStream(auth=twitter.OAuth(
        config["access_token"], config["access_token_secret"],
        config["consumer_key"], config["consumer_secret_key"]),
        secure=True)
    
    tweets = stream.statuses.sample(language='ja')
    for tweet in tweets:
        print(tweet["text"])


if __name__ == '__main__':
    get_tweet()