跟踪实时推文流中的关键字

我安装并尝试了 tweepy，我现在正在使用以下功能：

from API参考 http://packages.python.org/tweepy/html/api.html#api-reference

API.public_timeline()

返回最近 20 个状态 设置了自定义用户图标的非受保护用户。公众 时间线缓存 60 秒，因此请求频率高于 这是对资源的浪费。

但是，我想从完整的直播流中提取与某个正则表达式匹配的所有推文。我可以把public_timeline()里面一个while True循环，但这可能会遇到速率限制的问题。不管怎样，我真的不认为它可以涵盖所有当前的推文。

怎么可能呢？如果不是所有推文，那么我想提取与某个关键字匹配的尽可能多的推文。

流媒体 API 就是您想要的。我使用一个名为 tweetstream 的库。这是我的基本监听功能：

def retrieve_tweets(numtweets=10, *args):
"""
This function optionally takes one or more arguments as keywords to filter tweets.
It iterates through tweets from the stream that meet the given criteria and sends them 
to the database population function on a per-instance basis, so as to avoid disaster 
if the stream is disconnected.

Both SampleStream and FilterStream methods access Twitter's stream of status elements.
For status element documentation, (including proper arguments for tweet['arg'] as seen
below) see https://dev.twitter.com/docs/api/1/get/statuses/show/%3Aid.
"""   
filters = []
for key in args:
    filters.append(str(key))
if len(filters) == 0:
    stream = tweetstream.SampleStream(username, password)  
else:
    stream = tweetstream.FilterStream(username, password, track=filters)
try:
    count = 0
    while count < numtweets:       
        for tweet in stream:
            # a check is needed on text as some "tweets" are actually just API operations
            # the language selection doesn't really work but it's better than nothing(?)
            if tweet.get('text') and tweet['user']['lang'] == 'en':   
                if tweet['retweet_count'] == 0:
                    # bundle up the features I want and send them to the db population function
                    bundle = (tweet['id'], tweet['user']['screen_name'], tweet['retweet_count'], tweet['text'])
                    db_initpop(bundle)
                    break
                else:
                    # a RT has a different structure.  This bundles the original tweet.  Getting  the
                    # retweets comes later, after the stream is de-accessed.
                    bundle = (tweet['retweeted_status']['id'], tweet['retweeted_status']['user']['screen_name'], \
                              tweet['retweet_count'], tweet['retweeted_status']['text'])
                    db_initpop(bundle)
                    break
        count += 1
except tweetstream.ConnectionError, e:
    print 'Disconnected from Twitter at '+time.strftime("%d %b %Y %H:%M:%S", time.localtime()) \
    +'.  Reason: ', e.reason

我有一段时间没看过了，但我很确定这个库只是访问示例流（而不是消防水带）。 HTH。

编辑添加：你说你想要“完整的直播”，又名消防水带。这在财政和技术上都是昂贵的，并且只有非常大的公司才被允许拥有它。查看文档，您会发现该示例基本上具有代表性。