小编fji*_*01d的帖子

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

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

要登录我的python程序,我正在使用该python-logstash库:

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

我正在尝试使用python-logstashgithub页面上的示例将日志写入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库也不会返回任何错误或调试消息.

任何人都可以指出我做错了什么吗？

我logstash.conf包含以下内容:

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

output {
    elasticsearch {
        hosts => "elasticsearch:9200"
        codec => rubydebug
    }
}