前面的 ELK 中咱们是[用 Filebeat 收集 Docker 容器日志],利用的是 Docker 默认的 logging driver json-file
,本节咱们将使用 fluentd
来收集容器的日志。docker
Fluentd 是一个开源的数据收集器,它目前有超过 500 种的 plugin,能够链接各类数据源和数据输出组件。在接下来的实践中,Fluentd 会负责收集容器日志,而后发送给 Elasticsearch。日志处理流程以下:json
这里咱们用 Filebeat 将 Fluentd 收集到的日志转发给 Elasticsearch。这固然不是惟一的方案,Fluentd 有一个 plugin fluent-plugin-elasticsearch
能够直接将日志发送给 Elasticsearch。条条道路通罗马,开源世界给予了咱们多种可能性,能够根据须要选择合适的方案。elasticsearch
一样的,最高效的实践方式是运行一个 fluentd 容器。测试
docker run -d -p 24224:24224 -p 24224:24224/udp -v /data:/fluentd/log fluent/fluentd
fluentd 会在 TCP/UDP 端口 24224 上接收日志数据,日志将保存在 Host 的 /data
目录中。rest
fluentd 会在 TCP/UDP 端口 24224 上接收日志数据,日志将保存在 Host 的 /data
目录中。日志
编辑 Filebeat 的配置文件 /etc/filebeat/filebeat.yml
,将 /data
添加到监控路径中。code
重启 Filebeat。blog
systemctl restart filebeat.service
启动测试容器。ast
docker run -d \ --log-driver=fluentd \ --log-opt fluentd-address=localhost:24224 \ --log-opt tag="log-test-container-A" \ busybox sh -c 'while true; do echo "This is a log message from container A"; sleep 10; done;' docker run -d \ --log-driver=fluentd \ --log-opt fluentd-address=localhost:24224 \ --log-opt tag="log-test-container-B" \ busybox sh -c 'while true; do echo "This is a log message from container B"; sleep 10; done;'
--log-driver=fluentd
告诉 Docker 使用 Fluentd 的 logging driver。test
--log-opt fluentd-address=localhost:24224
将容器日志发送到 Fluentd 的数据接收端口。
--log-opt tag="log-test-container-A"
和 --log-opt tag="log-test-container-B"
在日志中添加一个可选的 tag,用于区分不一样的容器。
容器启动后,Kibana 很快就可以查询到容器的日志。