python - 在 ZSI Soap 中使用扭曲的 adbapi

Question

我是 python 新手，目前正在研究将其用作 SOAP 服务器的可行性。我目前有一个非常粗糙的应用程序，使用 mysql 阻塞 api，但想尝试扭曲的 adbapi。我已经使用 react 器在常规扭曲代码上成功使用了扭曲 adbapi，但似乎无法使用 ZSI 框架使其与下面的代码一起使用。它没有从 mysql 返回任何内容。有人曾经使用过扭曲的 adbapi 和 ZSI 吗？

import os
import sys
from dpac_server import *
from ZSI.twisted.wsgi import (SOAPApplication,
                          soapmethod,
                          SOAPHandlerChainFactory)
from twisted.enterprise import adbapi
import MySQLdb

def _soapmethod(op):
    op_request = GED("http://www.example.org/dpac/", op).pyclass
    op_response = GED("http://www.example.org/dpac/", op + "Response").pyclass
    return soapmethod(op_request.typecode, op_response.typecode,operation=op, soapaction=op)

class DPACServer(SOAPApplication):
    factory = SOAPHandlerChainFactory

    @_soapmethod('GetIPOperation')
    def soap_GetIPOperation(self, request, response, **kw):
        dbpool = adbapi.ConnectionPool("MySQLdb", '127.0.0.1','def_user', 'def_pwd', 'def_db', cp_reconnect=True)

        def _dbSPGeneric(txn, cmts):
            txn.execute("call def_db.getip(%s)", (cmts, ))
            return txn.fetchall()

        def dbSPGeneric(cmts):
            return dbpool.runInteraction(_dbSPGeneric, cmts)

        def returnResults(results):
            response.Result = results

        def showError(msg):
            response.Error = msg

        response.Result = ""
        response.Error = ""

        d = dbSPGeneric(request.Cmts)
        d.addCallbacks(returnResults, showError)

        return request, response

def main():
    from wsgiref.simple_server import make_server
    from ZSI.twisted.wsgi import WSGIApplication

    application         = WSGIApplication()
    httpd               = make_server('127.0.0.1', 8080, application)
    application['dpac'] = DPACServer()
    print "listening..."
    httpd.serve_forever()

if __name__ == '__main__':
    main()

Answer 1

您发布的代码为每个(某种)请求创建一个新的ConnectionPool，并且它永远不会停止池。这意味着您最终将耗尽资源，并且无法满足更多请求。 “最终”可能是在一两个或三个请求之后。

如果您从未收到任何回复，也许这不是您遇到的问题。但在某些时候这将成为一个问题。

经过仔细检查，我想知道这段代码是否运行了 Twisted react 器。第一次阅读时，我以为您正在使用一些 ZSI Twisted 集成来运行您的服务器。现在我发现您正在使用 wsgiref.simple_server。我有一定的信心认为这行不通。

您已经在使用 Twisted，use Twisted's WSGI server相反。

除此之外，验证 ZSI 是否在正确的线程中执行回调。 WSGI 应用程序默认在非 react 器线程中运行。 Twisted API 不是线程安全的，因此如果 ZSI 不采取措施纠正这一点，那么在线程中使用非线程安全 API 就会引入错误。