node-logstash-send

Fast send to logstash, ignore error, bypass waiting.

Install

npm install -s node-logstash-send

Configuration

• Logstash

Example of logstash/pipeline/logstash.conf.

input {
        tcp {
                port => 5000
        }
        http {
                host => "0.0.0.0"
                port => "4999"
        }
}

## Add your filters / logstash plugins configuration here
filter {
  if ! [lg_pattern_prefix] {
        mutate { add_field => { "[@metadata][lg_pattern_prefix]" => "logstash" } }
  } else {
        mutate { add_field => { "[@metadata][lg_pattern_prefix]" => "%{[lg_pattern_prefix]}" } }
  }
}

output {
        elasticsearch {
                hosts => "elasticsearch:9200"
                index => "%{[@metadata][lg_pattern_prefix]}-%{+YYYY.MM.dd}"
        }
}

Advanced configuration Docs.

• Set Environment variables.

export LOGSTASH_IP=xx
export LOGSTASH_PORT=1111
export LOGSTASH_QUIET=false

Usage

Send your interests.

process.env["LOGSTASH_IP"] = "venus";
process.env["LOGSTASH_PORT"] = 49991
var logstash = require('node-logstash-send')
logstash({
    lg_pattern_prefix: "logstash",
    hello: "bar"
    })

| key | description | | lg_pattern_prefix | used as index pattern prefix, the patten would be $lg_pattern_prefix.yyyy.MM.dd |

Note, it would ignore the error if send failed, to see errors, set LOGSTASH_QUIET as true .

what you get in Kibana

ELK

Setup ELK Services with

https://github.com/samurais/docker-elk

开源许可协议

Copyright (2019) 北京华夏春松科技有限公司

MIT