SCDF。 WSDL 源：Spring Cloud Task 或 Spring Cloud Stream 或任何其他解决方案？

Question

我们有从 SOAP Web 服务获取数据的要求，在该服务中将公开相同的记录。然后将记录转换并写入数据库。 我们是主动方，每隔一段时间我们会检查是否有新记录出现。

我们的主要目标是：

• 有一个用于设置间隔的调度程序

• 如果出现问题（例如，失去连接），有一个重试机制

• 对流程进行可视化控制 - 检查卡住的地方（如 SCDF 中的仪表板）

由于没有示例 wsdl 源应用程序，我想 Task（或 Stream ？）应该由我们自己编写。但是用什么来重复和调度......

在选择正确的方法时，我需要您的建议。

如果有其他更合适的解决方案，我不依赖 SCDF 解决方案。

Answer 1

如果您打算直接使用来自外部服务的 SOAP 消息，您可以构建自定义 Spring Cloud Stream 源或简单的 Spring Batch/Spring Cloud Task 应用程序。这两个选项都提供了弹性模式，包括重试。

但是，如果上游数据不是实时的，您将选择任务路径，因为流是长时间运行的，并且它们永远不会终止。另一方面，任务在有限的时间段内运行、终止并释放资源。还可以选择使用特定于平台的调度程序实现来触发定期在循环窗口上启动任务。

从 SCDF 仪表板，您可以 design/build 组合任务，包括 state transitions 和所需的下游操作。