from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
import time
s=raw_input('string');
try:
file = open('keyword.txt', 'r')
keyword=file.read()
ckey ='CONSUMER KEY'
csecret ='CONSUMER SECRET'
atoken ='ACCESS TOKEN'
asecret='ACCESS SECRET'
class listener(StreamListener):
def on_data(self, data):
# print data
tweet=data.split(',"text":"')[1].split('","source')[0]
print (tweet)
print ('\n')
saveThis=tweet
saveFile =open('projectdatabase.csv','a')
saveFile.write(saveThis )
saveFile.write('\n')
saveFile.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=[keyword])
except Exception:
Tags:
你的问题需要更具描述性,但是如果你想通过搜索获得特定数量的tweet…你可以参考这个例子
进口粗花呢 导入csv#导入csv 导入json 导入编解码器 导入日期时间
相关问题 更多 >
编程相关推荐