4

python sudsライブラリを使用して、ローカルの wsdl ファイルに基づいて SOAP クライアントを作成しています。私の目標は Twisted をバックエンドとして使用することなので、SOAP サーバーに非同期でクエリを実行します。

このトピックが何度も取り上げられてきたことは知っていますが ( here1、here2 )、まだいくつか質問があります。

私は泡でツイストを使用する 3 つの異なるアプローチを見てきました。

a) このパッチを suds ライブラリに適用します。

b)泡のフォークであるtwisted-sudsを使用します。

c)この投稿Client_Asyncの影響を受けて、ツイスト操作を使用して suds クライアントを実装しましたdeferToThread(完全に動作する要点はここClient_Syncにあります。いくつかのベンチマークを実行するために suds クライアントも実装しました)。

# Init approach c) code
from suds.client import Client as SudsClient
from twisted.internet.threads import deferToThread

class MyClient(SudsClient):
   def handleFailure(self, f, key, stats):
        stats.stop_stamp(error=True)
        logging.error("%s. Failure: %s" % (key, str(f)))

    def handleResult(self, result, key, stats):
        stats.stop_stamp(error=False)
        success, text, res = False, None, None
        try:
            success = result.MessageResult.MessageResultCode == 200
            text = result.MessageResult.MessageResultText
            res = result.FooBar
        except Exception, err:
            pass
        logging.debug('%40s : %5s %10s \"%40s\"' % (key, success, text, res))
        logging.debug('%40s : %s' % (key, self.last_sent()))
        logging.debug('%40s : %s' % (key, self.last_received()))

def call(stats, method, service, key, *a, **kw):
    stats.start_stamp()
    logging.debug('%40s : calling!' % (key))
    result = service.__getattr__(method)(*a, **kw)
    return result

class Client_Async(MyClient):
    """ Twisted based async client"""
    def callRemote(self, stats, method, key, *args, **kwargs):
        logging.debug('%s. deferring to thread...' % key)
        d = deferToThread(call, stats, method, self.service, key, *args, **kwargs)
        d.addCallback(self.handleResult, key, stats)
        d.addErrback(self.handleFailure, key, stats)
        return d

class Client_Sync(MyClient):
    def callRemote(self, stats,  method, key, *args, **kwargs):
        result = None
        try:
            result = call(stats, method, self.service, key, *args, **kwargs)
        except Exception, err:
            self.handleFailure(err, key, stats)
        else:
            self.handleResult(result, key, stats)
# End approach c) code

c) アプローチを使用して小規模なベンチマークを実行すると、非同期モデルの利点が示されます。

-- Sync model using Client_Sync of approach c).
# python soap_suds_client.py -t 200 --sync
Total requests:800/800. Success:794 Errors:6
Seconds elapsed:482.0
Threads used:1

-- Async model using Client_Async of approach c).
# python soap_suds_client.py -t 200
Total requests:800/800. Success:790 Errors:10
Seconds elapsed:53.0
Threads used:11

私はアプローチ a) または b) をテストしていません。私の質問は次のとおりです。

スレッドを 1 つだけ使用する以外に、それらから実際に得られるものは何ですか?

4

1 に答える 1

5

プロジェクトで泡を使用しています。パッチを当てたり、ねじれた泡を使用したりする必要はありませんでした。私はpython-sudsパッケージ（ubuntu上）の0.4.1-2バージョンを使用しており、非常に便利なnosendオプションが付属しています。

    # This parses the wsdl file. The autoblend option you'd probably skip, 
    # its needed when name spaces are not strictly preserved (case for Echo Sign).
    from suds import client
    self._suds = client.Client('file://' + config.wsdl_path, nosend=True,
                               autoblend=True)

    ....

    # Create a context for the call, example sendDocument() call. This doesn't yet
    # send anything, only creates an object with the request and capable of parsing
    # the response
    context = self._suds.service.sendDocument(apiKey=....)

    # Actually send the request. Use any web client you want. I actually use 
    # something more sophisticated, but below I put the example using 
    # standard twisted web client.
    from twisted.web import client
    d = client.getPage(url=context.client.location(), 
                       postdata=str(context.envelope),
                       method='POST',
                       headers=context.client.headers())

    # The callback() of the above Deferred is fired with the body of the 
    # http response. I parse it using the context object.          
    d.addCallback(context.succeeded)

    # Now in the callback you have the actual python object defined in 
    # your WSDL file. You can print...
    from pprint import pprint
    d.addCallback(pprint)
    # I the response is a failure, your Deferred would be errbacked with 
    # the suds.WebFault exception.
于 2013-10-31T13:18:26.557 に答える