创建了一个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
}
}