从python向logstash发送TCP数据失败

Question

input {
  tcp {
      port => 5959
      codec => json
  } 
}

filter{

}

output {
    stdout {codec => rubydebug}
}

巨蟒：

import json
import socket
import sys

HOST = "127.0.0.1"
PORT = 5959

try:
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    sys.stderr.write("[ERROR] %s\n" % msg[1])
    sys.exit(1)

try:
    sock.connect((HOST, PORT))
except socket.error, msg:
    sys.stderr.write("[ERROR] %s\n" % msg[1])
    sys.exit(2)

msg = {'@message': 'python test message', '@tags': ['python', 'test']}

sock.sendall(json.dumps(msg))
sock.send('\n')
sock.close()
sys.exit(0)

在执行了这两个脚本之后，我既不会得到任何错误，也不会得到日志存储中的数据，所以有人可以帮忙，比如是什么导致了这个问题。

Answer 1

我只是在sock.sendall(json.dumps(msg))后面添加了sock.send('\n')，它起作用了。看来logstash-codec-jsonAS1存在一个未解决的问题：

logstash“json”插件仍然需要换行符“\n”来终止通过TCP输入发送的json日志。2

参考资料：