Apache Camel中的并行处理及比较

kq4fsx7k  于 11个月前  发布在  Apache
关注(0)|答案(1)|浏览(112)

我目前在一个camel项目中工作,该项目需要触发一个调度器,该调度器将同时从两个单独的表(例如表A和B)读取数据,然后将它们的输出相互比较,准备最终列表并更新第一个表(表A)。这是我第一次使用Apache Camel,我真的没有太多的想法。不过下面分享一个大概的做法..好心帮忙。
类似这样的东西,我不想加入输出,而是希望两个结果集都可用于比较。

from("direct:start)
            .processor("process1")
            .processor("process2")
.to("direct:compareAndUpdate");

字符串

xmakbtuz

xmakbtuz1#

如果使用SQL组件读取表,则可以使用outputHeader选项将查询结果存储在不同的头中。
另外,您也可以使用Enrich弹性公网IP,按照自己的意愿对查询结果进行累积。
最后,您可以做一些简单的事情,将每个查询结果复制到一个头或属性。例如,在

.to("sql") // or whatever you're doing to get the data
.setHeader("results1", body())
.to("sql...") // or whatever you're doing to get the data
.setHeader("results2", body())

字符串

相关问题