如何配置logstash 2.3.3 websocket

我想让logstash 2.3.3 websocket输入工作。如何配置logstash 2.3.3 websocket

Logstash：https://download.elastic.co/logstash/logstash/logstash-2.3.3.tar.gz

WebSocket的输入插件Logstash：https://www.elastic.co/guide/en/logstash/current/plugins-inputs-websocket.html

的WebSocket服务器：https://github.com/joewalnes/websocketd/releases/download/v0.2.11/websocketd-0.2.11-linux_amd64.zip

的WebSocket客户端：浏览器插件 “简单的Web客户端的Socket”

我知道的去年提交的bug logstash 1.5.0和websocket输入插件。 https://github.com/logstash-plugins/logstash-input-websocket/issues/3我也收到了那些相同的错误信息，虽然我不能再现它们。以下是我目前的程序和结果。我希望这个错误已经得到修复，我无法找到正确的配置。

首先我安装了插件并确认它已列为已安装。

/app/bin/logstash-plugin list | grep "websocket"

接下来，我检查了logstash是用下面的配置

input { 
    stdin { } 
} 

output { 
    file { 
    path => "/app/logstash-2.3.3/logstash-log.txt" 
    } 
}

Logstash合作工作。

/app/logstash-2.3.3/bin/logstash agent --config /app/logstash-2.3.3/logstash.conf 
Hello World

文件logstash-log.txt的包含：

{"message":"Hello World","@version":"1","@timestamp":"2016-07-05T20:04:14.850Z","host":"server-name.domain.com"}

接下来，我打开端口9300

我写了一个简单的bash脚本返回一些数字

#!/bin/bash 

case $1 in 
    -t|--to) 
    COUNTTO=$2 
    shift 
    ;; 
esac 
shift 
printf 'Count to %i\n' $COUNTTO 

for COUNT in $(seq 1 $COUNTTO); do 
    echo $COUNT 
    sleep 0.1 
done

我启动websocketd指向我的bash脚本

/app/websocketd --port=9300 /app/count.sh --to 7

我的Chrome中打开简单的Web客户端的Socket连接

ws://server-name.domain.com:9300

成功！它返回了以下内容。

Count to 7 
1 
2 
3 
4 
5 
6 
7

在这一点上，我知道websocketd作品和logstash作品。现在是麻烦开始的时候。

Logstash WebSocket的输入配置文件

input { 
    websocket { 
    codec => "plain" 
    url => "ws://127.0.0.1:9300/" 
    } 
} 

output { 
    file { 
    path => "/app/logstash-2.3.3/logstash-log.txt" 
    } 
}

运行configtest

/app/logstash-2.3.3/bin/logstash agent --config /app/logstash-2.3.3/logstash.conf --configtest

接收 “配置OK”

启动websocketd

/app/websocketd --port=9300 /app/logstash-2.3.3/bin/logstash agent --config /app/logstash-2.3.3/logstash.conf

回到Simple Web Socket Client，我连接到ws：//server-name.domain.com：9300。我看到一个消息弹出，我开始了一个会话。

Tue, 05 Jul 2016 20:07:13 -0400 | ACCESS | session | url:'http://server-name.domain.com:9300/' id:'1467732248361139010' remote:'192.168.0.1' command:'/app/logstash-2.3.3/bin/logstash' origin:'chrome-extension://pfdhoblngbopfeibdeiidpjgfnlcodoo' | CONNECT

我尝试发送“hello world”。服务器上没有任何明显的情况。大约15秒后，我的控制台窗口中显示断开连接消息。 logstash-log.txt永远不会被创建。

有什么想法？谢谢！

更新1：

我试图把下面的称为 “launch_logstash.sh” bash脚本：

#!/bin/bash 

exec /app/logstash-2.3.3/bin/logstash agent --config /app/logstash-2.3.3/logstash.conf

然后，我开始websocketd像这样：

/app/websocketd --port=9300 /app/logstash-2.3.3/bin/launch_logstash.sh

同样的结果;没有成功。

来源

2016-07-05 Daniel

更仔细地阅读websocketd文档后，它将套接字上收到的数据发送到程序的stdin。我试图在logstash配置中听一个套接字，但数据实际上是要去那个应用的stdin。我改变了我的config来此：

input { 
    stdin { } 
} 

output { 
    file { 
    path => "/app/logstash-2.3.3/logstash-log.txt" 
    } 
}

随后推出websocketd这样的：

/app/websocketd --port=9300 /app/logstash-2.3.3/bin/logstash agent --config /app/logstash-2.3.3/logstash.conf

因此，在短期，直到logstash-WebSocket的输入实现他们的服务器选项，标准输入{}和stdout {}是如果使用websocketd作为Web服务器的输入和输出。

来源

2016-07-06 22:10:39 Daniel

如何配置logstash 2.3.3 websocket

回答

相关问题