Logstash REST 过滤器 - 限制速度



创建了一个logstash配置文件,该文件从MSSQL获取数据并将其推送到ElasticSearch,我正在使用Logstash REST过滤器来丰富数据

filter {
rest {
request => {
  url => "http://api.timezonedb.com/v2/get-time-zone? 
  key=[KEY]&format=json&by=zone&zone=Europe/%{city}"
  method => "post"   
}
json => true
sprintf => true 
target => "test"                    
}
}

我的问题是:

有没有办法限制/减慢日志,因为我使用的示例 API 返回了我进行过多调用的错误?

Logstash 中有一个过滤器睡眠插件,它应该对速率限制很有用。

配置示例:

filter {
  rest {
   # rest related
  }
  sleep {
    time => "1"   # Sleep 1 second
    every => 10   # on every 10th event
  }
}

最新更新