使用 logstash 流式传输 API

Question

我正在尝试使用 logstash exec 插件将 Twitter 流摄取到弹性中。由于 API 端点提供了推文流（decahose），exec 插件似乎无法正常工作。有没有更好的方法来处理 logstash？

Answer 1

我刚刚发现 'pipe' 输入插件比 logstash'exec' 插件工作得更好

 input {
  pipe {
    command => 'curl --compressed -v -u <<username>>:<<password>> "https://gnip-stream.twitter.com/stream/sample10/accounts/<<accountName>/publishers/twitter/<<env>>.json"'
    codec => "json"
  }
}