Logstash: вход из SQS не вставляется в InfluxDB - PullRequest
Новая
       14

Logstash: вход из SQS не вставляется в InfluxDB

0 голосов
/ 02 апреля 2019

Я пытаюсь вставить данные в InfluxDB, используя Logstash с методом ввода SQS: я отправляю сообщение в Sqs, а Logstash читает сообщения из Sqs и пытается поместить данные в InfluxDB.

Я установил logstash, как показано нижеоднако попытка вставить данные в influenxDB продолжает вызывать ошибку, сообщающую [WARN ][logstash.outputs.influxdb] Non recoverable exception while writing to InfluxDB {:exception=>#<Errno::EPIPE: Broken pipe - No message available>}.Как видите, вывод stdout выглядит нормально.Что я делаю не так?

Буду очень признателен за любой совет или предложение.

Заранее спасибо.

стандартный вывод 

{
      "userId" => 1,
         "lng" => 127,
    "@version" => "1",
  "@timestamp" => 2019-04-02T12:46:33.006Z,
         "lat" => 36
}

logstash.conf 

input {
    sqs {
        codec => "json"
        queue => "logstash-test"        
    }
}

output {
    stdout {}
    influxdb {
        measurement => "location"
        send_as_tags => ["userId"]
        data_points => {
            "userId" => "%{[userId]}"
            "lat" => "%{[lat]]}"
            "lng" => "%{[lng]]}"
        }
        host => "localhost"
        port => "xxxx"
        db => "db_name"
        codec => json
    }
}

Используемые плагины logstash: logstash-input-sqs logstash-output-influenxdb

...