将python日志文件写入logstash

我正在使用Docker提供的ELK堆栈:

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

要login我的python程序,我正在使用python-logstash库:

 https://github.com/vklochan/python-logstash 

我正在尝试使用python-logstash github页面上的示例将日志写入logstash(并在Kibana中查看后续数据):

 LOGGER = logging.getLogger('python-logstash-logger') LOGGER.setLevel(logging.INFO) LOGGER.addHandler(logstash.LogstashHandler(127.0.0.1, 5000, version=1)) LOGGER.error('python-logstash: test logstash error message.') 

但是,这不会将任何数据写入ElasticSearch,如下所示:

 http://127.0.0.1:9200/_search?pretty=true 

python-logstash库也没有返回错误或debugging信息。

任何人都可以指出我做错了吗?

我的logstash.conf包含以下内容:

 input { tcp { port => 5000 codec => json } } output { elasticsearch { hosts => "elasticsearch:9200" codec => rubydebug } } 

使用

 LOGGER.addHandler(logstash.TCPLogstashHandler(127.0.0.1, 5000, version=1))