Logstash Итерировать внутренние объекты и вставить в базу данных

Question

Я новичок в logstash, и у меня есть требование как текущее сценарий. У меня следующий формат журнала.

{"library":"xyz","locations":["location1":"abc","location2":"mno"]} 

Затем мне нужно добавить эти данные в базу данных в следующем формате.

• "место": "библиотека" (полей базы данных)
• "ABC": "хуг"
• "MnO": "хуг"

До сих пор я сделал извлечь json и поместить запись в базу данных. Но выше сценария мне нужно добавить две записи в базу данных. Мне нужно знать, как итерировать местоположение, и каждое место добавляет запись в базу данных. Ссылка на документацию или простой пример будет достаточно.

Это мой конф файл

input { 
file { 
    path=> "filePath" 
    start_position => beginning 
    sincedb_path => "/dev/null" 
} 
} 
filter { 

    grok{ 
     match => { "message" => "%{GREEDYDATA:request}"} 
    } 
    json{ 
      source => "request" 
      target => "parsedJson" 
    } 

    mutate { 
      add_field => 
      "locations" => "%{[parsedJson][locations]}" 
      "library" => "%{[parsedJson][library]}" 
      } 
      remove_field => ["request", "message", "@version", "host", "parsedJson"] 
    } 

} 
output { 
    stdout { 
    codec => rubydebug 
    } 
    mongodb{ 
      collection => "library" 
      database => "db" 
      uri => "mongodb://127.0.0.1:27017" 
    } 

} 

Answer 1

Вы можете быть в состоянии добиться того, что вы хотите с split filter, что создает отдельные события для каждого разделения поля. Если у вас было два места в разделенных запятыми массив можно использовать

split { 
    target => "field" 
    terminator => "," 
} 

Что бы создать отдельное событие для каждого значения, разделенные запятыми.