import tweepy
from tweepy.api import API

API_KEY = 'OrJhTNJr5Hw2QMJ8E4IgkGZwm'
API_SECRET = 'rioB3YDXIgff0d5RaxsQ6bNVqPIxyo1F8623HociYYQ0PjW5d4'
ACCESS_TOKEN = '216244556-DMl9QY2qbPBzhbPDXik4WyxMktbYts7VRZdS7LsL'
ACCESS_TOKEN_SECRET = 'Wx7eGa4mLXG2AD9vYC3HBJ3ID0oRPlauVeMzTKvFAggVR'
key = tweepy.OAuthHandler(API_KEY, API_SECRET)
key.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)

class Stream2File(tweepy.StreamListener):
    def __init__(self, api=None):
        self.api = api or API()
        self.n = 0
        self.m = 2
        self.output = open('/Users/santoshkumar/Desktop/PB_Phase1.txt', 'w')

    def on_status(self, data):
        self.output.write(data.text.encode('utf8') + "\n")
        self.n = self.n+1
        if self.n < self.m:
            print(data)

            return True
        else:
            self.output.close()
            print 'tweets = '+str(self.n)
            return False

stream = tweepy.streaming.Stream(key, Stream2File())
stream.filter(track=['Peyton'])