我目前有一项服务,它运行多个查询来在我的数据库中构建数据。然后它使用 Logstash 的 JDBC 输入插件将数据发送到 Elastic Search。问题是 Logstash 需要相当多的时间引导(有时超过将数据发送到 Elastic Search 所需的时间)。
我决定探索让 Logstash 作为服务运行以消除这个引导时间,但是似乎没有办法让它作为服务运行并接受“请求”来运行 JDBC 语句。
最接近的似乎是使用 TCP/HTTP/Websocket 插件从我的服务接收数据,然后将其发送到 Elastic Search。
尝试开发类似的东西是否有意义,或者使用我的服务直接与 Elastic Search 通信会更好吗?
我希望我的问题足够清楚,谢谢。