我有一个用例，我必须通过传递来自Kafka的输入作为主体，对logstash中的API端点进行外部HTTP调用，并读取API调用的输出，将其存储在elasticsearch索引中。我们可以通过HTTP过滤器插件实现这一点吗？如果可以，我的主要问题是我们如何读取API调用的输出，并将其索引到elasticsearch中。我还看到了一些所谓的http轮询插件，这是什么东西，将对我有用？帮助将不胜感激。谢谢。
ljsrvy3e1#
这很简单，您可以使用HTTP Pooler，类似于：
input { # 1. trigger new token requests every hour http_poller { urls => { pipelines => "http://localhost:9600/_node/stats/pipelines?pretty" } schedule => { cron => "*/1 * * * *"} codec => "json" metadata_target => "http_poller_metadata" } }
然后使用如下elasticsearch输出：
output { elasticsearch { hosts => ["localhost:9200"] } }
您可以在此处获得更多信息我希望这对你有用。
1条答案
按热度按时间ljsrvy3e1#
这很简单，您可以使用HTTP Pooler，类似于：
然后使用如下elasticsearch输出：
您可以在此处获得更多信息
我希望这对你有用。