2015-08-25 1 views
1

Я хочу обновить одно поле моего документа/войти в elasticsearch из logstash.Как увеличить количество полей моего документа в логсташе?

Мой logstash конф файл

input { 
    http { 
    host => "127.0.0.1" # default: 0.0.0.0 
    port => 31311 # default: 8080 
    } 
} 

output { 
    stdout { codec => json }, 
    elasticsearch { 
     action => "update" 
     bind_host => "127.0.0.1" 
     bind_port => 9200 
     document_id => "ET00009682" 
     index => "in12" 
     type => "event" 
    } 
} 

Я хочу, чтобы увеличить свой отсчет поля один как указать, что в моем выходе logstash.

Примечание: Я знаю, что для обновления мне нужно использовать этот скрипт

"script" : "ctx._source.count += 1" 

, но я не уверен, куда поместить его в выходе logstash?

Пожалуйста, помогите спасибо

ответ

0

Так что я сделал, был уволен запрос curl от выхода logstash для достижения этого.

2

вы можете сделать это с конф:

output { 
    stdout { codec => json }, 
    elasticsearch { 
     action => "update" 
     bind_host => "127.0.0.1" 
     bind_port => 9200 
     document_id => "ET00009682" 
     index => "in12" 
     type => "event" 
     doc_as_upsert => true 
     script => "ctx._source.count += 1" 
     script_lang => "groovy" 
     script_type => "inline" 
    } 
} 
Смежные вопросы