非同期要求のRPCオブジェクトからの応答URLの取得方法App Engine？

Question

rpcs = [] 
for url in urls: 
    rpc = urlfetch.create_rpc(deadline=5.0) 
    urlfetch.make_fetch_call(rpc, url) 
    rpcs.append(rpc) 
while len(rpcs) > 0: 
    rpc = apiproxy_stub_map.UserRPC.wait_any(rpcs) 
    res = rpc.get_result() 
    if res.status_code == 200: 
    ...... do something with result 
    rpcs.remove(rpc) 

どのようにurlが応答を受け取ったかを判断するには？

Answer 1

使用するコールバック：

def handle_result(rpc, url): 
    ..... [your code goes here] 

def create_callback(rpc, url): 
    return lambda: handle_result(rpc, url) 

rpcs = [] 
for url in urls: 
    rpc = urlfetch.create_rpc(deadline=5.0) 
    rpc.callback = create_callback(rpc, url) 
    urlfetch.make_fetch_call(rpc, url) 
    rpcs.append(rpc) 

while rpcs: 
    rpc = apiproxy_stub_map.UserRPC.wait_any(rpcs) 
    rpcs.remove(rpc)