云服务器价格_云数据库_云主机【优惠】最新活动-搜集站云资讯

网站服务器_手机百度云zip怎么解压_安全稳定

小七 141 0

网站服务器_手机百度云zip怎么解压_安全稳定

在以前的博客中,我谈到了如何保证SDK发布者的数据交付。这一次,我将讨论如何使用REST和WebSocket连接实现流式Web服务(SWS)发布者的GD。在每一节中,我将为您指出流分析安装中的一个文件,淘客采集软件,您可以在其中看到一个实际的示例。这些示例文件包含在streaming analytics SP 02修订版022及更新版本的服务器和客户端软件包中。

在继续阅读之前,请记住,要实现GD,您要发布到的项目必须:

将consistent recovery属性设置为true,并且auto cp trans属性使用非零值。

发布到带有SWS的项目时,您可以通过请求SWS在发布数据后发出提交来保证交付。增加了对发布提交的支持:

2.0 SP 00 for REST publishing2.0 SP 02 for WebSocket publishing

WebSocket publishing只需要定期提交GD即可工作。但是,为了保证使用REST发布的订单交付,SWS必须对每个发布请求发出提交。

在2.0 SP 00及更高版本中使用REST请求发布

,每次发送REST请求以将消息发布到流或窗口时,可以通过在publish请求中将commit属性设置为true(默认值为false)来实现GD。这样做,就是告诉SWS在发布行之后向项目发出一个commit。必须为每个REST发布请求发出提交,以确保数据按顺序发布到项目。

例如,云服务器免,考虑发布请求R1、R2、R3和R4,其中只有R4请求提交。如果项目在R1发布之后停止,而在R4发布之前又恢复,这将导致无序交付,其中只有R1和R4被发布和提交。例如,为了使用REST发布,您需要请求SWS在每个发布请求中发出一个提交,并等待请求成功后再发送下一个请求。

要查看REST发布保证交付的示例,查看$STREAMING\u HOME/examples/python/swsgd/rest中的代码示例_示例.py.

使用WebSocket连接发布

从2.0 SP 02开始,您可以通过提交模式(默认为单工模式)连接来保证使用WebSocket连接发布时的数据传递。提交模式允许您:

通过在发布消息中将Commit属性指定为true(默认值为false)来发出定期提交,并且异步接收来自SWS的响应消息,指示发布和提交请求是成功还是失败。

与REST发布不同,企业管理平台软件,使用WebSocket连接发布时,不需要对每个发布请求或消息发出提交。在SWS处理发布消息时发生发布/提交失败或连接错误时,会删除后续消息,直到连接重置。当客户端向SWS发送"连接重置"消息时,连接被重置。

因此,软件企业条件,对于R1-R4的前一个示例,其中只有R4请求提交,如果项目在R1发布后停止,R2-R4(以及任何后续消息)将被丢弃,直到连接被重置。客户端必须发送"连接重置"消息并重新发送R1-R4。这确保了数据的有序传递。

要查看WebSocket发布的示例,请查看$STREAMING\u HOME/examples/python/swsgd/WebSocket中的代码示例_示例.py.

,大数据是