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

金山云_白雪公主百度云_优惠

小七 141 0

在本系列的第一篇博客中,我讨论了什么是保证交付,它是如何工作的,以及为什么您应该将它用于流项目和适配器。如果您错过了它,您可以阅读这里的介绍。

现在,在第二部分中,我将讨论如何在三种不同的场景中使用订阅的保证传递:绑定、流式输出适配器和SDK订阅服务器。

如果您使用绑定,如何使用项目绑定的保证传递订阅

在两个不同项目的流或窗口之间,请确保在项目配置(CCR)文件中为项目添加必要的保证交付选项,用云服务器,可以通过studio:

或通过文本编辑器:

,因为本示例中使用的窗口都是输入窗口,必须设置为true,绑定才能正常工作–否则源输入窗口将无法将数据正确传输到其他项目中的输入窗口。

必须设置为true,或者必须在studio中选中Enable Guaranted Delivery,大数据工具,绑定才能使用Guaranted Delivery。为GD会话指定一个唯一的名称(unique\u session\u 1),或者设置一个批大小,大数据查询,或者如果源窗口处于带检查点的GD模式,则启用GD缓存。

批大小将决定收集多少事务,直到源窗口将它们发送到目标窗口,并且绑定发出GD commit。GD缓存将缓存传入的事务,直到绑定从源窗口接收到检查点消息–然后它将发送所有事务并发出提交。

如何订阅输出适配器的保证传递

要在输出适配器上使用GD,第一步是使用支持GD的适配器。您可以查看适配器指南中的适配器摘要表,查看哪些适配器支持保证交付,以及需要为要使用的适配器设置哪些参数。

每个适配器都有用于启用GD的参数。这些参数可以在studio中通过打开适配器的属性对话框来设置。例如,必须将enableGDMode参数设置为true,适配器才能在保证传递模式下运行。

enableGDcache参数默认为true,这会导致适配器仅将智能数据流服务器重新启动时可以恢复的行发送到其外部服务,并在内部缓存所有其他行。但是,将GD缓存与适配器一起使用可能会导致延迟增加,这取决于适配器连接到的流或窗口发出检查点消息的频率。

gdBatchSize确定适配器向其服务发出提交命令和向其连接的流或窗口发出GD提交之前需要多少消息块,因此,它接收到的数据行多久可以被它的服务使用。

您还可以将相应的CCL代码添加到您的项目中以设置相同的参数,如下面使用SAP HANA输出适配器的示例:

确保为您的适配器设置所有必要的GD参数,并根据您的项目需要选择正确的值。

如何为SDK订户订阅保证交付

在本例中,我将使用.NET SDK,尽管这三个SDK的步骤非常相似。您可以在这里查看方法,然后在SDK指南中查看C和Java SDK的详细信息。

1。致电:

网申请GD订阅EspSubscriberOptions.set\u gd\u会话(字符串session\u name

并创建NetEspSubscriber对象。

2。创建并连接NetEspPublisher对象。

3。通过调用:

N检索最后一个检查点数据的检查点序列号etEspSubscriberEvent.get\检查点\序列号\u(NetEspError^错误)。

4。通过呼叫:

告诉服务器订户已提交到给定序列号的消息,并且不再需要它们NetEspPublisher.commit\u gd(字符串^session\u name,数组^流ID,数组^序号,netesprerror^错误)。

5。一旦不再需要GD会话,请通过关闭订阅服务器或调用以下命令取消GD会话以释放资源:NetEspProject.cancel\u gd\u subscriber\u会话(String ^gd\u session,netesprerror ^error)。

请参阅SDK指南,以获取对SDK订户使用保证交付的更完整示例。

有关使用保证交付和一致恢复的更多信息:

零数据丢失使用绑定连接CCL项目使用存储进行数据保留和恢复请参阅适配器指南,好评返现文案,了解如何使用保证交付的适配器。

,便宜的云服务器