python - 如何从 WSDL 文件构建一个肥皂服务器?
问题描述
我正在尝试从 WSDL 文件创建一个肥皂服务器。我正在使用 Python 3 和 Spyne 来生成它。该服务器需要具体,因为客户端已经存在。我需要我的 WSDL 请求如下所示
<soapenv:Body>
<pus:receiveEvents>
<!--Optional:-->
<eventQueryResult>
<!--Optional:-->
<queryId>?</queryId>
<!--Optional:-->
<queryStatus>?</queryStatus>
<!--Zero or more repetitions:-->
<events>
<!--Optional:-->
<eid>?</eid>
<!--Optional:-->
<eventMessage>?</eventMessage>
<!--Optional:-->
<eventSeverity>?</eventSeverity>
<!--Optional:-->
<eventTime>?</eventTime>
<!--Optional:-->
<eventTypeName>?</eventTypeName>
<!--Optional:-->
<meterId>?</meterId>
</events>
<subscriptionId>?</subscriptionId>
</eventQueryResult>
</pus:receiveEvents>
</soapenv:Body>
但是,这是我的 WSDL 请求:
<soapenv:Body>
<pus:receiveEvents>
<!--Optional:-->
<pus:eventQueryResult>
<!--Optional:-->
<pus:queryId>?</pus:queryId>
<!--Optional:-->
<pus:queryStatus>?</pus:queryStatus>
</pus:eventQueryResult>
<!--Optional:-->
<pus:events>
<!--Optional:-->
<pus:eid>?</pus:eid>
<!--Optional:-->
<pus:eventMessage>?</pus:eventMessage>
<!--Optional:-->
<pus:eventSeverity>?</pus:eventSeverity>
<!--Optional:-->
<pus:eventTime>?</pus:eventTime>
<!--Optional:-->
<pus:eventTypeName>?</pus:eventTypeName>
<!--Optional:-->
<pus:meterId>?</pus:meterId>
</pus:events>
<pus:subscriptionId>
<!--Optional:-->
<pus:subscriptionId>?</pus:subscriptionId>
</pus:subscriptionId>
</pus:receiveEvents>
</soapenv:Body>
这是我写的代码
class eventQueryResult(ComplexModel):
__namespace__ = 'http://pushevent.nbapi.cgms.cisco.com/'
queryId = String
queryStatus = String
class events(ComplexModel):
__namespace__ = 'http://pushevent.nbapi.cgms.cisco.com/'
eid = String
eventMessage = String
eventSeverity = String
eventTime = Long
eventTypeName = String
meterId = String
class subscriptionId(ComplexModel):
__namespace__ = 'http://pushevent.nbapi.cgms.cisco.com/'
subscriptionId = Long
class EventPushService(ServiceBase):
__tns__ = 'http://pushevent.nbapi.cgms.cisco.com/'
__wsdl__ = 'http://schemas.xmlsoap.org/wsdl/'
@rpc(eventQueryResult.customize(min_occurs=0), events.customize(min_occurs=0), subscriptionId.customize(min_occurs=1,nillable = True), _returns=ResponseData)
def receiveEvents(ctx, eventQueryResult, events, subscriptionId):
eid = events.eid
return print(eid)
我需要 eventQueryResult 包含事件,但我不知道如何。Spyne 的文档对此没有帮助。
感谢您的意见
解决方案
这里有几件事要做。代码很不完整,所以做了一些假设。这非常接近 spyne 示例应用程序,与您发布的代码片段可以确定的内容相匹配。
当您创建类以对数据建模时,您希望eventQueryResult
包含事件。数组是文档here。该代码看起来更像:
class events(ComplexModel):
eid = String
eventMessage = String
eventSeverity = String
eventTime = Long
eventTypeName = String
meterId = String
class eventQueryResult(ComplexModel):
queryId = String
queryStatus = String
events = Array(events)
当您指定 RPC 时,函数的名称是 soapAction,首先是客户端将发送给您的对象的模型。在这里,整个有效载荷被建模为一个对象。Bare 意味着负载不会被包装在数组中。根据您的客户,这可能需要更改。
@rpc(eventQueryResult, _body_style='bare', _returns=someResponse)
someResponse 是您要发送回客户端的响应的模型。我真的不知道你想要什么,一系列被接受的事件怎么样?整个脚本如下所示:
import logging
from spyne import Application, rpc, ServiceBase, \
String, Long
from spyne.protocol.soap import Soap11
from spyne.server.wsgi import WsgiApplication
from spyne.model.complex import ComplexModel, Array
logging.basicConfig(level="WARNING")
class event(ComplexModel):
eid = String
eventMessage = String
eventSeverity = String
eventTime = Long
eventTypeName = String
meterId = String
class eventQueryResult(ComplexModel):
queryId = String
queryStatus = String
events = Array(event)
class someResponse(ComplexModel):
eventIds = Array(String)
class EventPushService(ServiceBase):
@rpc(eventQueryResult, _body_style='bare', _returns=someResponse)
def receiveEvents(ctx, req):
print(req)
return someResponse(eventIds = [ i.eid for i in req.events ] )
application = Application([EventPushService],
tns='http://pushevent.nbapi.cgms.cisco.com/',
in_protocol=Soap11(validator='lxml'),
out_protocol=Soap11()
)
if __name__ == '__main__':
# You can use any Wsgi server. Here, we chose
# Python's built-in wsgi server but you're not
# supposed to use it in production.
from wsgiref.simple_server import make_server
wsgi_app = WsgiApplication(application)
server = make_server('0.0.0.0', 80, wsgi_app)
server.serve_forever()
我正在使用看起来像的有效负载进行测试
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:tns="http://pushevent.nbapi.cgms.cisco.com/">
<soapenv:Header/>
<soapenv:Body>
<tns:receiveEvents>
<tns:queryId>100</tns:queryId>
<tns:queryStatus>Success</tns:queryStatus>
<tns:events>
<tns:event>
<tns:eid>someId</tns:eid>
<tns:eventMessage>someEventMessage</tns:eventMessage>
<tns:eventSeverity>someEventSeverity</tns:eventSeverity>
<tns:eventTime>1614974343</tns:eventTime>
<tns:eventTypeName>eventType</tns:eventTypeName>
<tns:meterId>meterStayOnTheMeter</tns:meterId>
</tns:event>
<tns:event>
<tns:eid>someId2</tns:eid>
<tns:eventMessage>someEventMessage2</tns:eventMessage>
<tns:eventSeverity>someEventSeverity2</tns:eventSeverity>
<tns:eventTime>1614974344</tns:eventTime>
<tns:eventTypeName>eventType2</tns:eventTypeName>
<tns:meterId>meterStayOnTheMeter2</tns:meterId>
</tns:event>
</tns:events>
</tns:receiveEvents>
</soapenv:Body>
</soapenv:Envelope>
我正在使用 curl 命令,例如curl localhost -d @payload -H 'SOAPAction: "receiveEvents"' -H "Content-type: text/xml; charset='UTF-8'"
推荐阅读
- javascript - 使用javascript / node js的地图方法在某些地方不起作用
- jquery - 使用 jquery 选择器和 ajax 将表行值传递给控制器
- pip - 参数包的类型
我们无法在 Ansible 中转换为列表错误 - html - 电话输入自动填充删除国际前缀
- mongodb - 如何在 Windows 上设置 MongoDB 日志轮换?
- java - 尝试调用虚拟方法 'void androidx.recyclerview.widget.RecyclerView.setAdapter
- c++ - 不同的输出取决于我是否打印返回值
- r - 如何在闪亮服务器的反应函数中添加多个输入变量?
- python - 从 index.ts 触发导出可执行脚本命令
- pandas - 在熊猫中单独计算时间增量