twitter_api.py 文件源码

def get_tweets(user, auth_token):
    tweets = []
    global tweet_gets_in_interval
    while len(tweets) < MAX_TWEETS_PER_USER:
        if len(tweets) == 0:
            lowest_id = "" # first run
        else:
            lowest_id = "&max_id=" + str(tweets[len(tweets) - 1].id - 1)

        req = urllib.request.Request(TWEETS_API_URL + "?screen_name=" + user + "&count=" + str(TWEETS_PER_REQ) + "&include_rts=false" + lowest_id)
        req.add_header("Authorization", auth_token)
        raw = urllib.request.urlopen(req).read().decode('utf-8')
        processed = json.JSONDecoder().decode(raw)
        if len(processed) == 0:
            break
        for tweet in processed:
            tweets.append(Tweet(tweet))

    return tweets