【发布时间】:2017-05-24 03:22:17
【问题描述】:
我是 Spark Streaming 的初学者。 我正在测试一些功能性的代码,但我想用它做其他事情。我只想检索我帐户中最受欢迎的两个主题标签。
class StdOutListener(StreamListener):
def on_data(self, data):
print data
return True
def on_error(self, status):
print status
if __name__ == '__main__':
l = StdOutListener()
auth = OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
stream = Stream(auth, l)
stream.filter(track=['python'])
我该怎么做?
非常感谢。
【问题讨论】:
-
Filtering in tweepy 的可能重复项。这并没有解决“我帐户上的前两个主题标签”问题,但我觉得要求用户在样板之上写这么多是过分的。
标签: python python-2.7 twitter spark-streaming tweepy