Logstash выход обусловливающие связи elasticsearch

Question

настоящее время я использую logstash для анализа и вывода результатов нескольких аналогичных команд elasticsearch, похожее на это:

input { 
    exec { 
    type => 'hist' 
    command => '/usr/bin/somecommand' 
    interval => 900 
    codec => "json" 
    } 

    exec { 
    type => 'hist' 
    command => '/usr/bin/somecommand' 
    interval => 900 
    codec => "json" 
    } 

    exec { 
    type => 'hist' 
    command => '/usr/bin/somecommand' 
    interval => 900 
    codec => "json" 
    } 
} 

output { 
     if [type] == "hist" { 
       elasticsearch { 
         hosts => ["hostname.domain.com:9200"] 
         index => "monitor-hist-%{+YYYY-MM-dd}" 
       } 
     } 
} 

То, что я хотел бы, чтобы иметь возможность для вывода stdout или файл, если соединение с поиском elasticsearch завершается неудачно, например:

if _connectionfails_ { 
    stdout { 
      codec => rubydebug 
    } 
} 

Возможно ли это? Или любые другие рекомендации по управлению данными, когда эластичность недоступна?

Answer 1

Logstash сохраняет все события в основной памяти во время обработки. Logstash отвечает на SIGTERM, пытаясь остановить входные данные и ожидание ожидающих событий для завершения обработки перед закрытием. Когда трубопровод не может быть сброшен из-за застрявшего выхода или фильтра, Logstash ждет неопределенно долго. Например, когда конвейер отправляет выходные данные в базу данных, недоступную экземпляру Logstash, экземпляр ожидает неопределенный срок после получения SIGTERM.