ReadTimeoutError：Twitter 流 API

我想得到一些关于攻击性狗的推文。我的关键字在代码中指定。它们都指的是德国牧羊犬（西班牙语“pastor alemán”）。 例如，除了我希望收到的其他推文之外this one https://twitter.com/EducaRacional/status/569847674305953793完全符合关键字并于 2015 年 2 月 23 日发布。 我执行了下面给出的代码，等待大约 1 小时后出现以下错误：

requests.packages.urllib3.exceptions.ReadTimeoutError: HTTPSConnectionPool(host='stream.twitter.com', port=443): Read timed out.

看来443端口有问题，如何解决这个问题？

附：该代码适用于“python、javascript”等关键字。

UPDATE:我注意到，如果我用英语编写关键字，例如“德国牧羊犬攻击性”，代码会检索一些推文。但随后我收到另一条错误消息：

socket.error: [Errno 10054] An existing connection was forcibly closed by the remote host

My code:

from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
import time

CONSUMER_KEY = "..."
CONSUMER_SECRET = "..."
ACCESS_TOKEN = "..."
ACCESS_TOKEN_SECRET = "..."

class listener(StreamListener):

    def on_data(self, data):
        try:
            print data
            saveFile = open('raw_tweets.json', 'a')
            saveFile.write(data)
            saveFile.write('\n')
            saveFile.close()
            return True

        except BaseException, e:
            print 'failed ondata,', str(e)
            time.sleep(10)
            pass

    def on_error(self, status):
        print status
        if status == 420:
            return False


if __name__ == '__main__':
    auth = OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
    auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET)
    stream = Stream(auth, listener())

    keywords = ['pastor aleman agresivo','pastor aleman muerde',
                'pastor aleman mata','pastor aleman muerte',
                'pastor aleman peligroso','pastor aleman peligro',
                'pastor aleman adiestramiento']
    stream.filter(track=keywords)

捕获这些错误并重新启动流。出现错误是正常的。连接可能会因多种您无法控制的原因而中断。此外，如果 90 秒后没有任何活动，Twitter 将关闭连接。

编辑： 有人发了一个example https://stackoverflow.com/questions/23601634/how-to-restart-tweepy-script-in-case-of-error使用 tweepy 可以完成与您需要的类似的操作。