我们有一个场景,我们必须处理数据库表中的每个数据条目。但这应该是用户在决定开始处理时触发的。
我们对流处理很满意,因为我们可以将每个流程步骤解耦到流应用程序中,并根据需要对其进行扩展。我们的另一个选择是让它成为批处理作业的任务。
如果我们要通过流来做到这一点,我们正在考虑一种方法来拥有一个 http 源(获取触发器)-> jdbc 源/处理器(检索每条记录)-> 应用程序处理器(处理每条记录)-> jdbc sink(保存到数据库)
有没有优雅的解决方案或其他方式通过spring cloud stream和spring cloud data flow来做到这一点?