我有一个Django管理命令,通过supervisord启动,它使用tweepy来使用twitter流API。
代理运行得很好,但是我注意到日志中每10-15分钟有一个SSLError,并且supervisord正在重新启动代理。
tweepy软件包是最新的,版本1.11。服务器是Ubuntu12.04LTS。我已经试过将cacert安装到下面链接中提到的密钥链中,但是没有成功。
Twitter API SSL Root CA Certificate
有什么建议吗?
[2012-08-26 19:28:15,656: ERROR] Error establishing the connection
Traceback (most recent call last):.../.../datasinks.py", line 102, in start
stream.filter(locations=self.locations)
File "/site/pythonenv/local/lib/python2.7/site-packages/tweepy/streaming.py", line 228, in filter
self._start(async)
File "/site/pythonenv/local/lib/python2.7/site-packages/tweepy/streaming.py", line 172, in _start
self._run()
File "/site/pythonenv/local/lib/python2.7/site-packages/tweepy/streaming.py", line 117, in _run
self._read_loop(resp)
File "/site/pythonenv/local/lib/python2.7/site-packages/tweepy/streaming.py", line 150, in _read_loop
c = resp.read(1)
File "/usr/lib/python2.7/httplib.py", line 541, in read
return self._read_chunked(amt)
File "/usr/lib/python2.7/httplib.py", line 574, in _read_chunked
line = self.fp.readline(_MAXLINE + 1)
File "/usr/lib/python2.7/socket.py", line 476, in readline
data = self._sock.recv(self._rbufsize)
File "/usr/lib/python2.7/ssl.py", line 241, in recv
return self.read(buflen)
File "/usr/lib/python2.7/ssl.py", line 160, in read
return self._sslobj.read(len)
SSLError: The read operation timed out
下面是代码的概要。
from tweepy import API, OAuthHandler
from tweepy.streaming import StreamListener, Stream
# snip other imports
class TwitterSink(StreamListener, TweetSink):
def __init__(self):
self.auth = OAuthHandler(settings.TWITTER_OAUTH_CONSUMER_KEY, settings.TWITTER_OAUTH_CONSUMER_SECRET)
self.auth.set_access_token(settings.TWITTER_OAUTH_ACCESS_TOKEN_KEY, settings.TWITTER_OAUTH_ACCESS_TOKEN_SECRET)
self.locations = '' # Snip for brevity
def start(self):
try:
stream = Stream(self.auth, self,timeout=60, secure=True)
stream.filter(locations=self.locations)
except SSLError as e:
logger.exception("Error establishing the connection")
except IncompleteRead as r:
logger.exception("Error with HTTP connection")
# snip on_data()
# snip on_timeout()
# snip on_error()
Github上提供了另一种替代解决方案:
https://github.com/tweepy/tweepy/pull/132
这是我的方法(从这里修改的解决方案https://groups.google.com/forum/?fromgroups=#!topic/tweepy/80Ayu1joGJ4):
证书似乎不是问题所在。这个错误只是一个超时。我觉得tweepy的SSL处理有问题。The code可以处理
socket.timeout
并重新打开连接,但不是通过SSLError
到达的超时。不过,看看
ssl
模块code(或docs),我看不出一个很好的方法来捕捉它。SSLError
对象没有任何参数,只是一个字符串描述。由于缺乏更好的解决方案,我建议在line 118 of tweepy/streaming.py之前添加以下内容:为什么一开始就超时是个好问题。我没有什么比重复特拉维斯·梅林格关于设置更高的
timeout
更好的了。相关问题 更多 >
编程相关推荐