spring-boot - Logstash与Spring Cloud数据流,哪个适合数据预处理?

标签 spring-boot elasticsearch elastic-stack spring-cloud-dataflow

我正在使用spring boot以及elasticsearch在我的网站上制作一个搜索系统。
我需要一些数据来进行 flex 搜索,必须在处理该数据(例如产品)之前(将其传递到另一个过滤JSON的微服务中,添加一些字段以获得更好的搜索结果,然后进行一些计算)返回我要存储的对象)。是否可以通过日志存储来做到这一点,或者我需要使用Spring Cloud Data Flow吗?提前致谢。
我想做的事:

save a product ( product service ) 
log the saved product or stream it.
process it before storage ( another service ) 
save the document ( elastic search server )

提前致谢。

最佳答案

显然,这取决于各种因素,但是我可以尝试从技术 Angular 对Spring Cloud Data Flow提出一些见解。
如果您想要构建一个流水线管道,通过执行此数据处理流程的消息传递系统连接您的过滤应用程序,则可以 checkout Spring Cloud Data Flow。
Spring Cloud Data Flow(以及诸如Spring Cloud Stream和Spring Cloud Task之类的基础框架支持)在如何管理流传输管道方面提供了操作上的好处,但如果不需要带有消息传递系统的数据管道,则可能没有任何意义。等等,在那种情况下,您只会坚持使用一个简单的Spring Boot应用程序来完成整个过滤模型。一旦您开始探索通过消息传递系统松散耦合的这些应用程序的分发,Spring Cloud Data Flow将非常方便。
请结帐SCDF guide以了解featuresrecipes的更多信息,以了解SCDF可以提供的内容并选择适合您的情况。

关于spring-boot - Logstash与Spring Cloud数据流,哪个适合数据预处理?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63360702/

相关文章:

尝试使用 Thymeleaf 加载 HTML 文件时出现 Spring Boot 404

java - 蒙戈错误: Spring Boot throws E11000 duplicate key error

elasticsearch集群设置信息

yaml - 解码 filebeat 配置中的错误

spring-boot - 如何在SpringBoot 3中配置zipkin的baseUrl

java - 如果使用 ducusign API 通过模板发送嵌入式签名,则没有签名工具

ruby - 在Travis上将Elasticsearch版本指定为2.3.1

java - Elasticsearch:如何使产品名称在搜索中比产品描述更重要?

elasticsearch - 线程 “Thread-21” java.lang.NoSuchFieldError中的异常:FAIL_ON_SYMBOL_HASH_OVERFLOW

docker - 无法使Metricbeat使用传递的env变量