用于流数据的 Logstash Elasticsearch 输入插件
Logstash Elasticsearch Input Plugin for streaming data
我想知道我们是否可以使用 logstash-input-elasticsearch 插件来传输数据，例如：如果我的数据库中有可用数据并且我 运行 ElasticSearch 输入插件，它将为数据编制索引进入输出，但如果一段时间后有更多数据来自 ElasticSearch 数据库，ElasticSearch 输入插件是否能够在不重新启动 logstash 的情况下索引该数据？
感谢您的关注和帮助。
默认情况下，elasticsearch 输入将 运行 在您的 ES 实例上进行滚动查询，抽取与查询匹配的文档，将它们流式传输到您的输出，完成后 Logstash 将关闭。
但是，您可以设置一个 cron 作业，定期启动您的 Logstash 管道并查询 ES 中存在的新文档。
我想知道我们是否可以使用 logstash-input-elasticsearch 插件来传输数据，例如：如果我的数据库中有可用数据并且我 运行 ElasticSearch 输入插件，它将为数据编制索引进入输出，但如果一段时间后有更多数据来自 ElasticSearch 数据库，ElasticSearch 输入插件是否能够在不重新启动 logstash 的情况下索引该数据？
感谢您的关注和帮助。
默认情况下，elasticsearch 输入将 运行 在您的 ES 实例上进行滚动查询，抽取与查询匹配的文档，将它们流式传输到您的输出，完成后 Logstash 将关闭。
但是，您可以设置一个 cron 作业，定期启动您的 Logstash 管道并查询 ES 中存在的新文档。