如何使用logstash和elastic配置本机python日志库？

Question

我是 ELK 堆栈的新手，正在尝试学习如何配置本机 python 日志记录功能以在 LogStash 的帮助下更新我的弹性数据库。我发现的资源对我来说不太清楚，我想知道这里是否有人可以帮助我完成基本步骤。从这几个步骤开始，我是否走在正确的轨道上？

1. 为 LogStash 设置配置文件
2. 检索“记录器”[logging.getLogger()] 并向其中添加一个 Logstash 处理程序，其中主机是弹性数据库 URL？
3. 下一步？

任何帮助将不胜感激，谢谢。

Answer 1

您应该使用python-logstash模块。

它的用法记录在README 中。

import logging
import logstash
import sys

host = 'localhost'

test_logger = logging.getLogger('python-logstash-logger')
test_logger.setLevel(logging.INFO)
test_logger.addHandler(logstash.LogstashHandler(host, 5959, version=1))
# test_logger.addHandler(logstash.TCPLogstashHandler(host, 5959, version=1))

test_logger.error('python-logstash: test logstash error message.')
test_logger.info('python-logstash: test logstash info message.')
test_logger.warning('python-logstash: test logstash warning message.')