1

私のコードは継続的なデータを提供しますが、データをフィルター処理して 5 分間持続させたいと考えていました。さらに、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