tornado 并行异步，如何保证在只有部分请求成功后，结果依旧可用。

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

Tornado Documentation

? http://www.v2ex.com/tornado/

Tornado on GitHub

? https://github.com/facebook/tornado/

Tornado Gists

? http://tornadogists.org/

这是一个创建于 2859 天前的主题，其中的信息可能已经有所发展或是发生改变。

（腾讯云最新优惠活动来了：云产品限时1折，云服务器低至88元/年，点击这里立即抢购：9i0i.cn/qcloud，更有2860元代金券免费领取，付款直接抵现金用，点击这里立即领取：9i0i.cn/qcloudquan）

（福利推荐：你还在原价购买阿里云服务器？现在阿里云0.8折限时抢购活动来啦！4核8G企业云服务器仅2998元/3年，立即抢购>>>：9i0i.cn/aliyun）

tornado 可以使用如下方式并行异步请求。

@gen.coroutine
def get(self):
    http_client = AsyncHTTPClient()
    response1, response2 = yield [http_client.fetch(url1),
                                  http_client.fetch(url2)]

这个时候， 1,2 是同时发送出去的，也就是说使用这种方式，可以让 n 个请求，同时发出去，等他们都返回了再统一返回。

那么我要如何保证，其中一个请求坏了，其余的结果依旧可用？

请求

Tornado

Fetch

异步

3 条回复 ? 2016-07-01 13:43:15 +08:00

gulu

2016-07-01 10:51:57 +08:00 via Android

你把右边的函数改一下，做一个 `try ... except ...`，保证无论如何函数都有返回。

kinghui

2016-07-01 13:40:52 +08:00

加个 wrapper 包装一下:
```
@gen.croutine
def _proxy(method, *args, **kwargs):
try:
ret = yield method(*args, **kwargs)
except ErrorYourWantCatch:
# logging or something else
ret = None
raise gen.Return(ret)

@gen.coroutine
def get(self):
http_client = AsyncHTTPClient()
response1, response2 = yield [_proxy( http_client.fetch, url1),
_proxy( http_client.fetch, url2)]
```

kinghui

2016-07-01 13:43:15 +08:00

@kinghui <script src="https://gist.github.com/coldnight/b5114a570f148c7aa124e4da3fb362a8.js"></script>