0

我们有一个场景,我们必须处理数据库表中的每个数据条目。但这应该是用户在决定开始处理时触发的。

我们对流处理很满意,因为我们可以将每个流程步骤解耦到流应用程序中,并根据需要对其进行扩展。我们的另一个选择是让它成为批处理作业的任务。

如果我们要通过流来做到这一点,我们正在考虑一种方法来拥有一个 http 源(获取触发器)-> jdbc 源/处理器(检索每条记录)-> 应用程序处理器(处理每条记录)-> jdbc sink(保存到数据库)

有没有优雅的解决方案或其他方式通过spring cloud stream和spring cloud data flow来做到这一点?

4

1 回答 1

1

如果您想通过流处理此问题,那么您可以http在每次想要由用户显式触发时发布消息源。或者,如果您想配置固定延迟或 cron 触发器之类的东西,您可以使用 OOTBtrigger应用程序

如果这可以通过任务来处理,那么 Spring Data Flow GUI/Shell 提供了task launch用户可以触发task execution.

于 2016-12-01T09:02:29.773 回答