grequest
目前,我执行以下操作来为我的包装器设置最大连接重试次数:
self._s = Session()
retries = Retry(total=5, status_forcelist=[500, 502, 503, 504])
self._s.mount('http://, HTTPAdapter(max_retries=retries))
grequest
然后,我以会话self._s
作为参数之一创建了一堆对象。例如,创建一组GET
请求将使用以下方式完成:
requests = [grequests.get(url, ..., 'session': self._s')]
最后,这些最终都使用grequests.map(requests, ...)
.
问题是我想要一种使最大重试次数持续存在并在连接池的所有连接之间共享的方法。重试似乎仍然仅适用于单个连接。有什么可能的方法吗?这是不可能的,因为新Retry()
对象似乎是在每次减少总调用时创建的?