python - 解析 SOAP 通知

Question

我有一个设备，可以定期向我计算机中运行的 HTTP 服务器发送 SOAP 通知。通知如下所示:

<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">
    <SOAP-ENV:Body>
        <Notify>
            <DeviceNotification message= "
                    <NotificationEvent NotificationType="Location">
                            <ComputerLocation changedOn="1369757031051">
                            </ComputerLocation>
                    </NotificationEvent>
                "/>
        </Notify>
    </SOAP-ENV:Body>
</SOAP-ENV:Envelope>

它是一个 SOAP 信封，其中包含 DeviceNotification 类型实例的 XML 表示形式。

我真的不知道如何处理这些通知(好像我的程序是服务器？客户端？)。该通知看起来更像是对命令的响应，但实际上我没有调用任何远程服务(发送通知的计算机有一个 Web 界面，我在其中输入“通知的目的地:此 IP、此端口”，然后它开始发送它们)我也不确定通知中的 SOAP 是否完全正确。

我已经尝试了几个 SOAP 库等等...我认为我能够实现的最接近的事情是使用 spyne (或者也许只是一个海市蜃楼，我认为这是因为它比其他库输出更多的东西)

class DeviceNotification(ComplexModel):
        ___namespace__ = ""
        pass

class HelloWorldService(ServiceBase):
    @rpc(DeviceNotification, _returns=Iterable(Unicode))
    def Notify(message):
        logging.warn("CHECKPOINT")
        print "message: %s" % message
        return ["foobarbaz"]

if __name__=='__main__':
    from wsgiref.simple_server import make_server
    PORT=7171
    application = Application([HelloWorldService],
                tns="",
                in_protocol=HttpRpc(validator='soft'),
                out_protocol=JsonDocument()
            )
    wsgi_application = WsgiApplication(application)
    server = make_server('', PORT, wsgi_application)
    server.serve_forever()

但是Notify函数永远不会被调用。我得到:

192.168.1.33 - - [28/May/2013 21:16:52] "POST / HTTP/1.1" 404 130
DEBUG:spyne.server.wsgi:Method name: '{}'
DEBUG:spyne.protocol.http:  header : {'soapaction': ['Notify'], 'host': ['niuyorker.jome:7171'], 'user_agent': ['Jakarta Commons-HttpClient/3.1']

这是我得到的最接近的东西。该 SOAP 消息正确吗？如果是，是否应将其视为对服务器(我的服务器)的请求或响应(因此，我的应用程序将是客户端)。如果有人知道在哪里可以找到比添加两个数字或多次说“Hello”更复杂的 Python 和 SOAP 示例，这也会有所帮助？

我想我总是可以使用 lxml解析整个 SOAP 消息，但如果可能的话，我想做得更“专业”一点。以防万一您没有注意到:我是 SOAP 服务的新手! :)

提前谢谢您!

更新:

看起来消息部分实际上应该是转义的 XML，这......好吧......这就是我从一开始实际上得到的，但是(因为我是新手)我转义了它，所以它在问题中看起来更漂亮。真实情况是:

 <soap-env:envelope xmlns:soap-env="http://schemas.xmlsoap.org/soap/envelope/">
 <soap-env:body>
  <notify>
   <notification message='&lt;NotificationEvent NotificationType="Location"&gt;&lt;DeviceLocation changedOn="1369074622065"&gt;&lt;/DeviceLocation&gt;&lt;/NotificationEvent&gt;'>
   </notification>
  </notify>
 </soap-env:body>
</soap-env:envelope>

我有 WSDL。使用suds我已经能够创建“ComputerLocation”类型的实例，例如:

>>> from suds.client import Client
>>> url="file:///tmp/service.wsdl"
>>> c=Client(url)
>>> c.factory.create('DeviceLocation')
(DeviceLocation){
   _changedOn = ""
 }

但这几乎就是我能做的一切。

说实话，我还是不知道我需要服务器还是客户端......

Answer 1

您使用的是 in_protocol=HttpRpc 而不是 in_protocol=Soap11。

HttpRpc protocol简单地定义为:

The so-called ReST-ish HttpRpc protocol implementation.

虽然还不完全清楚这意味着什么，但可以肯定的是，它不会尝试解析 SOAP 1.1 消息来查找命令，因为这与 REST-ish 相差并不远。有可能。

<小时/>

已经克服了这一点，并给出了您更新的(正确的)示例:

它被解析为有效的 XML，并且位于有效的 SOAP 1.1 信封中。

但它仍然不是好的 SOAP。正文的内容没有命名空间，也不是带有参数的结构化对象。事实上，整个内容是一个通用 XML 树，而实际内容是另一个通用 XML 树，它以转义形式存储为外部树中节点的属性。

从您的一个示例来看，我猜测 URL 路径始终为 /，并且 SOAP 结构始终只是直接位于 SOAP 信封。当然，如果您与框架的斗争足够多，您可能可以让它在 Notify 上分派(dispatch)，但无论如何您的所有消息最终都会出现在同一个地方，所以......为什么还要麻烦呢？您可能想要分派(dispatch)的内容(如果有的话)是嵌入 XML 内的内容，例如 NotificationType。

如果这些猜测是正确的，请使用您知道如何使用的最熟悉的 Web 服务器 — 您甚至不需要 WSGI；您可以使用 WSGI。如果需要，只需为 http.server.HTTPServer 编写一个简单的处理程序，并将每条消息路由到相同的代码，该代码执行足够的解析以获取 NotificationEvent 对象，并且从那里 dispatch 。像这样的事情:

from xml.etree import ElementTree as ET

def handle_location(nevent):
    clocation = nevent.find('ComputerLocation')
    changed_on = clocation.attrib['changedOn']
    location = clocation.text
    # do something with this info

def handle_other_thing(nevent):
    # whatever

handlers = {'Location': handle_location,
            'OtherThing': handle_other_thing }

et = ET.fromstring(body)
for notification in et.iter('notification'):
    message = ET.fromstring(notification.attrib['message'])
    for nevent in message.iter('NotificationEvent'):
        ntype = nevent.attrib['NotificationType']
        handlers[ntype](nevent)

听起来您可能拥有 NotificationEvent 中最低级别字段的 WSDL，因此您可以使用 suds 来代替手动解析 etree。那个级别，如果它使您的生活更轻松或使您的代码更灵活。

当然，您需要添加一些错误处理。