使用spring-xd查找

Question

我正在尋找使用spring-xd執行查找操作的方法。

我的問題陳述是這樣的，

我進來的JSON事件流，我想有事件的值查到的在HDFS或直接從RDBMS在我的文件針對的閾值。

請建議一種方法來執行此操作。

感謝您提前。

Answer 1

如果我理解正確，那麼對於消息中的不同值，您有不同的閾值。

喜歡的東西

值 'A' - > 100

值 'B' - > 200

...

該信息被存儲在文件中或在關係數據庫。現在您要根據它們的值和相應的閾值過濾事件。

我想你將不得不編寫一個自定義的處理器來保存這些值存儲在數據庫的連接，並查詢它們。如果映射足夠小，您應該考慮兌現它，或者至少緩存最常用的值，這樣不會減慢流。

Answer 2

如果我理解你的問題，你可以編寫一個groovy處理器來接收有效載荷，過濾它，然後將它傳遞到你想要的任何地方，像hdfs。

stream --name --def "jdbc | groovyprocessor | hdfs" --deploy 

在批次的情況下，您將需要編寫自定義模塊。

莫哈