У нас есть настройка ELK с filebeat, logstash иasticsearch и kibana. Мне нужен совокупный запрос и ответ на logstash.
Я настроил конфигурацию конвейера, как показано ниже. Теперь агрегация журнала работает без каких-либо проблем, если я использую одного работника для конвейера. если я использую несколько рабочих, агрегация не происходит. какое-либо решение использовать несколько рабочих и агрегирование журналов?
if [transaction] == "request" {
aggregate {
task_id => "%{id}"
code => "
map['method'] = event.get('method')
map['request'] = event.get('request')
map['user'] = event.get('user')
map['application'] = event.get('application')"
map_action => "create"
}
drop {}#drop the request before persisting, to save indexing space in elasticsearch server
}
if [message] =~ "TRANSACTION:response" {
aggregate {
task_id => "%{id}"
code => "
event.set('method', map['method'])
event.set('response', map['response'])
event.set('user', map['user'])
event.set('application', map['application'])"
map_action => "update"
}
}