1

我的代码提供了连续的数据,但我想将数据过滤到持续五分钟。此外,我想每 1 分钟报告一次。我需要为此做些什么?

try:
    import json
except ImportError:
    import simplejson as json

from twitter import Twitter, OAuth, TwitterHTTPError, TwitterStream

ACCESS_TOKEN = 'secret'
ACCESS_SECRET = 'secret'
CONSUMER_KEY = 'secret'
CONSUMER_SECRET = 'secret'

oauth = OAuth(ACCESS_TOKEN, ACCESS_SECRET, CONSUMER_KEY, CONSUMER_SECRET)

twitter_stream = TwitterStream(auth=oauth)

iterator = twitter_stream.statuses.filter(track="car", language="en")

for tweet in iterator:
    try:
        if 'text' in tweet: 
            print tweet['user']['name'] 
            print tweet['user']['statuses_count']
            # print '\n'
            for hashtag in tweet['entities']['hashtags']:
                hashtags.append(hashtag['text'])
            print hashtags

    except:
        continue

提前致谢。

4

0 回答 0