twitter.py

from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
import json
import sentiment_mod as s

#consumer key, consumer secret, access token, access secret.
ckey="FXcfKPba6evno1RN4bnQm05rY"
csecret="jFndJFIeUKmdUkYvRtTgKegKT9RRlTJxOrVcMiU79kcRWLBZBn"
atoken="4687407942-IGj5C6tSp97tO1D5W04ZnX9cdLkCH3DxwtBLbkw"
asecret="xQk3oKTuFFOAFGXCzIN4wHsTkdQwNns0dZhbgAbMx73nO"

class listener(StreamListener):

    def on_data(self, data):
    	all_data = json.loads(data)
    	tweet = all_data["text"]
    	sentiment_value, confidence = s.sentiment(tweet)
    	print(tweet, sentiment_value, confidence)

    	if confidence*100 >= 80:
    		output = open("Data/twitter-out.txt","a")
    		output.write(sentiment_value)
    		output.write('\n')
    		output.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=["car"])