彈簧數據流w/2源提供一個處理器/接收器

Question

我正在尋找建立一個特定用例的Spring數據流流的建議。

我的使用情況：

我有2 RDBMS，我需要比較針對每個運行的查詢的結果。查詢應該大致同時運行。根據比較結果，我應該可以通過我創建的自定義電子郵件接收器應用程序發送電子郵件。

我設想流圖看起來像這樣（對不起，油漆）：

的問題是，日本自衛隊沒有，據我所知，允許流與2個源組成。在我看來，像這樣的事情應該是可能的，而不必將框架的限制推得太遠。我正在尋找解決方案，在SDF框架內工作時爲這種情況提供了一個很好的方法。

我使用Kafka作爲消息代理，數據流服務器使用mysql來保存流信息。

我已經考慮創建一個自定義的源應用程序，它輪詢兩個數據源並在輸出通道上發送消息。這將消除我對2個源的需求，但看起來它需要對jdbc源應用程序進行大量的定製。

在此先感謝。

Answer 1

我還沒有真正嘗試過這種方式，但是您應該可以使用命名的目標來實現這一點。看看這裏：http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced

stream create --name jdbc1 --definition "jdbc > :dbSource"

stream create --name jdbc2 --definition "jdbc > :dbSource"

stream create --name processor --definition ":dbSource > aggregator | sink"