from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
import time


#consumer key, consumer secret, access token, access secret.
ckey=
csecret=
atoken=
asecret=

class listener(StreamListener):
#count=0
    def on_data(self, data):

        #while (count<10):
            #count++;
            tweet=data.split(',"text":"')[1].split('","source')[0]
            print(tweet+"\n")
            savefile=str(time.time())+"::"+tweet
            save=open('twitterDB4.csv','a')
            save.write(savefile)
            save.write("\n\n")
            save.close()
            return(True)

    def on_error(self, status):
        print (status)

auth = OAuthHandler(ckey, csecret)
auth.set_access_token(atoken, asecret)

twitterStream = Stream(auth, listener())
twitterStream.filter(track=["hello"])