logstash-tcp 安装
yarn add logstash-tcp
使用方法
const logstash = require('logstash-tcp')
logstash.init({
host: '192.168.40.167',
port: '9600'
})
logstash.send({
hostname: 'wdd2',
id: i++,
something: {
name: 'abc'
}
})kibana查询结果
{
"_index": "logstash-2019.03.07",
"_type": "logs",
"_id": "AWlWzhwpixOdAdKBNE2p",
"_score": null,
"_source": {
"hostname": "wdd2",
"@timestamp": "2019-03-07T06:19:02.050Z",
"port": 55666,
"@version": "1",
"host": "192.168.2.184",
"id": 7,
"something": {
"name": "abc"
},
"tags": [
"_grokparsefailure"
]
},
"fields": {
"@timestamp": [
1551939542050
]
},
"highlight": {
"hostname": [
"@kibana-highlighted-field@wdd2@/kibana-highlighted-field@"
]
},
"sort": [
1551939542050
]
}logstash.init(options) 全部配置
| 字段 | 类型 | 默认值 | 说明 |
|---|---|---|---|
| socketTimeout | int | 10000 | socket超时毫秒数 |
| port | int | logstash tcp端口号 | |
| host | string | ||
| reconnectTimeout | int | 2000 | 发生异常时，多少毫秒后开始重连 |
| maxReconnectTimes | int | 10 | 最多多少次重连 |
| logBufferSize | int | 1000 | 当发生异常时，最多缓存多少个待发送的日志。当下次重连成功后，这些日志会再次尝试发送。 |
logstash.send(msg)
msg是一个可以被序列化的对象。
logstash.send({
key: 'what u want'
})