在Tornado中嵌套Web服务调用（异步？）

Question

我正在用tornado（还有一个第三方的tornadows模块）实现一个SOAP网络服务。我的服务里有一个操作需要调用另一个操作，所以我有了以下的流程：

外部请求（通过SOAPUI）到操作A
内部请求（通过requests模块）到操作B
从操作B得到的内部响应
从操作A得到的外部响应

因为所有操作都在一个服务里运行，所以在某个地方出现了阻塞。我对tornado的异步功能不太熟悉。

只有一个请求处理方法（post），因为所有请求都是通过同一个网址进来的，然后根据SOAPAction请求头的值调用具体的操作（处理的方法）。我在post方法上加了@tornado.web.asynchronous装饰器，并在最后调用了self.finish()，但还是不行。

tornado能处理这种情况吗？如果可以，我该怎么实现呢？

编辑（添加代码）：

class SoapHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def post(self):
        """ Method post() to process of requests and responses SOAP messages """
        try:
            self._request = self._parseSoap(self.request.body)
            soapaction = self.request.headers['SOAPAction'].replace('"','')
            self.set_header('Content-Type','text/xml')
            for operations in dir(self):
                operation = getattr(self,operations)
                method = ''
                if callable(operation) and hasattr(operation,'_is_operation'):
                    num_methods = self._countOperations()
                    if hasattr(operation,'_operation') and soapaction.endswith(getattr(operation,'_operation')) and num_methods > 1:
                        method = getattr(operation,'_operation')
                        self._response = self._executeOperation(operation,method=method)
                        break
                    elif num_methods == 1:
                        self._response = self._executeOperation(operation,method='')
                        break
            soapmsg = self._response.getSoap().toprettyxml()
            self.write(soapmsg)
            self.finish()
        except Exception as detail:
            #traceback.print_exc(file=sys.stdout)
            wsdl_nameservice = self.request.uri.replace('/','').replace('?wsdl','').replace('?WSDL','')
            fault = soapfault('Error in web service : {fault}'.format(fault=detail), wsdl_nameservice)
            self.write(fault.getSoap().toxml())
            self.finish()

这是请求处理器的post方法。它来自我使用的网络服务模块（所以不是我的代码），但我加了异步装饰器和self.finish()。基本上，它就是根据请求中的SOAPAction调用正确的操作。

class CountryService(soaphandler.SoapHandler):
    @webservice(_params=GetCurrencyRequest, _returns=GetCurrencyResponse)
    def get_currency(self, input):
        result = db_query(input.country, 'currency')
        get_currency_response = GetCurrencyResponse()
        get_currency_response.currency = result
        headers = None
        return headers, get_currency_response

    @webservice(_params=GetTempRequest, _returns=GetTempResponse)
    def get_temp(self, input):
        get_temp_response = GetTempResponse()
        curr = self.make_curr_request(input.country)
        get_temp_response.temp = curr
        headers = None
        return headers, get_temp_response

    def make_curr_request(self, country):

        soap_request = """<soapenv:Envelope xmlns:soapenv='http://schemas.xmlsoap.org/soap/envelope/' xmlns:coun='CountryService'>
   <soapenv:Header/>
   <soapenv:Body>
      <coun:GetCurrencyRequestget_currency>
         <country>{0}</country>
      </coun:GetCurrencyRequestget_currency>
   </soapenv:Body>
</soapenv:Envelope>""".format(country)

        headers = {'Content-Type': 'text/xml;charset=UTF-8', 'SOAPAction': '"http://localhost:8080/CountryService/get_currency"'}
        r = requests.post('http://localhost:8080/CountryService', data=soap_request, headers=headers)
        try:
            tree = etree.fromstring(r.content)
            currency = tree.xpath('//currency')
            message = currency[0].text
        except:
            message = "Failure"
        return message

这些是网络服务的两个操作（get_currency和get_temp）。所以SOAPUI请求get_temp，这个操作会通过make_curr_request和requests模块发起一个SOAP请求去获取get_currency。然后结果应该就这样返回，发回给SOAPUI。

这个服务的实际操作没有什么意义（请求温度却返回货币），但我只是想让功能正常工作，这就是我现在的操作。

网络服务请求处理 soap 异步编程 soapui 模块化阻塞 tornado

在Tornado中嵌套Web服务调用（异步？）

2 个回答

撰写回答