stream_twitter_from_file.py

#!/usr/bin/env python

"""
Pre-requisites:
For this application we are using tweepy. Install it if required. 
$ pip install tweepy

Sign up for an app in https://apps.twitter.com/
"""

import tweepy
import json

consumer_key = "6IqHdMvf8nodHMs7IMwOjSxBT"
consumer_secret = "uvgQGUYHm1nW3MaI7FFdkZ3GAeD1bIOWSv6MMen0OoZF9f3Nyr"

access_token = "15101127-AY4CWdyMSavHbyjQfrg2K2YX73A0pBz6e58HZ8im5"
access_token_secret = "DEPgC5UetWVgGHK0mqsFViSDl5vtEz1zjsAeiccQZ4I6D"

auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)

api = tweepy.API(auth)

class MyStreamListener(tweepy.StreamListener):
    def on_status(self, status):
        print(status.text)
        message = json.dumps(status._json).encode("utf-8")
        with open("tweets/%d.json" % status.id, "wb") as f:
          f.write(message)
        
    def on_error(self, status_code):
        print("Error code: ", status_code)
        
myStreamListener = MyStreamListener()
myStream = tweepy.Stream(auth = api.auth, listener=myStreamListener)
myStream.filter(track=["trump"])