Я настраиваю logstash
, чтобы вставить серию json
файлов в elasticsearch
облако, это мой файл конвейера, если я его использую, logstash вставляет данные одного файла в отдельные файлы, используя полеmennsage: (one line of my json)
и используя индекс по умолчанию.Мои json-файлы имеют специальный индекс и все остальные поля.
input
{
file
{
path => "/PRTGBeat/data/generated/*.json"
mode => "read"
sincedb_path => "/dev/null"
start_position => "beginning"
file_completed_action => "log_and_delete"
file_completed_log_path => "/PRTGBeat/data/processed/AllDocuments.log"
}
}
filter
{
mutate
{
replace => [ "message", "%{message}" ]
gsub => [ 'message','\n','']
}
if [message] =~ /^{.*}$/
{
json { source => message }
}
}
output
{
elasticsearch
{
hosts => ["my host"]
user => "elastic"
password => "mypasword"
}
}
что я могу сделать, чтобы вставить данные без изменения моих файлов?