Docker ELK + docker-compose + filebeat部署教程

前言

目前主流日志采集系统,采用elk + filebeat来实现,记录一下部署的流程。

1. 所需资源:docker运行环境

2. 安装镜像sebp/elk

// 拉取镜像
docker pull sebp/elk:7.12.0

3. 使用docker-compose启动容器

  1. 安装docker-compose
    详见 https://docs.docker.com/compose/install/
  2. 创建挂载镜像elk-data,记录elasticsearch的存储内容(以用于如果容器销毁后重新创建,也可以重新加载数据)
docker volume create elk-data
  1. 创建挂载镜像elk-log,记录所有elk内的log日志
docker volume create elk-log
// 可以查看elk-log具体的挂载信息
sudo docker volume inspect elk-log
// 如果需要映射到/var/log下面
sudo mkdir /var/log/elk
sudo mount --bind /var/lib/docker/volumes/elk-log/_data /var/log/elk/
  1. 临时启动镜像,用于copy配置文件下来
// 启动镜像
sudo docker run -d sebp/elk:7.12.0
// 创建应用目录
mkdir /opt/elk
mkdir /opt/elk/elasticsearch
mkdir /opt/elk/logstash
mkdir /opt/elk/kibana
// cp出各个单服务的配置文件
sudo docker cp CONTAINER_ID:/opt/kibana/config/kibana.yml /opt/elk/kibana/.
sudo docker cp CONTAINER_ID:/etc/logstash/conf.d/30-output.conf /opt/elk/logstash/.
sudo docker cp CONTAINER_ID:/etc/logstash/conf.d/11-nginx.conf /opt/elk/logstash/.
sudo docker cp CONTAINER_ID:/etc/elasticsearch/elasticsearch.yml /opt/elk/elasticsearch/.
// 销毁创建的容器
sudo docker stop CONTAINER_ID
sudo docker rm CONTAINER_ID
  1. 修改elasticsearch配置文件,/opt/elk/elasticsearch/elasticsearch.yml
## 结尾增加如下配置,用于启用登录权限(xpack安全验证)
xpack.security.enabled: true
xpack.license.self_generated.type: basic
xpack.security.transport.ssl.enabled: true
  1. 修改kibana的配置文件,/opt/elk/kibana/kibana.yml
## 增加中文配置
i18n.locale: "zh-CN"
## es 设置的kibana用户名称
elasticsearch.username: "kibana"
## es 设置的kibana用户名称,此处密码是在后续进行设置,先预设admin1
elasticsearch.password: "admin1"
  1. 修改logstash的配置文件,/opt/elk/logstash/30-output.conf
## 修改为如下配置
output {
  elasticsearch {
    hosts => ["localhost"]
    manage_template => false
    index => "%{[fields][type]}-%{+YYYY.MM.dd}" ## 生成索引key
    user => "elastic"
    password => "admin1" ## admin1也是预设,后续会进行配置
  }
}
  1. 创建docker-compose.yml配置文件,并放置在/opt/elk/目录下
elk:
    image: sebp/elk:7.12.0
    ports:
      - "5601:5601"
      - "9200:9200"
      - "5044:5044"
    volumes:
      - elk-data:/var/lib/elasticsearch
      - elk-log:/var/log
      - /opt/elk/kibana/kibana.yml:/opt/kibana/config/kibana.yml
      - /opt/elk/logstash/30-output.conf:/etc/logstash/conf.d/30-output.conf
      - /opt/elk/logstash/11-nginx.conf:/etc/logstash/conf.d/11-nginx.conf
      - /opt/elk/elasticsearch/elasticsearch.yml:/etc/elasticsearch/elasticsearch.yml
    environment:
      "ES_CONNECT_RETRY": "180" ## ES的启动最大允许时间
      "ES_HEAP_SIZE": "4g" ## ES的最大堆内存
      "LS_HEAP_SIZE": "1g" ## logstash的最大堆内存
    restart: always
    privileged: true ## 使docker内的elk拥有外部root权限
  1. 启动docker-compose
sudo docker-compose up -d elk
  1. 配置es密码
## 进入容器内部
sudo docker exec -it CONTAINER_ID /bin/bash
## 执行命令,交互式设置密码(注意保存好全部密码)
sh /usr/share/elastic/bin/elasticsearch-setup-passwords interactive
## 和之前在kibana和logstash内的配置文件设置的密码相同即可
  1. ES内置用户介绍
Elastic内置用户
elastic:内置超级用户
kibana:仅可用于kibana用来连接elasticsearch并与之通信, 不能用于kibana登录
logstash_system:用于Logstash在Elasticsearch中存储监控信息时使用
  1. 此时已经可以登录kibana了,http://IP:5601

4. 安装filebeat & Log4j配置

1. log4j的xml配置,filebeat读取固定格式的日志文件,解析到logstash内,此处展示一个推荐的log4j配置(其中LOG_PATTERN内的trace_id需要用到spring-cloud-sleuth,用于分布式链路追踪)
<?xml version="1.0" encoding="UTF-8"?>
<!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
<!--Configuration后面的status,这个用于设置log4j2自身内部的信息输出,可以不设置,当设置成trace时,你会看到log4j2内部各种详细输出-->
<!--monitorInterval:Log4j能够自动检测修改配置 文件和重新配置本身,设置间隔秒数-->
<configuration status="WARN" monitorInterval="30">

    <Properties>
        <!--格式化输出-->
        <property name="LOG_PATTERN" value="%p|%d{yyyy-MM-dd HH:mm:ss:SSS}|%X{X-B3-TraceId}|%15.15t|%c:%L| %msg%n"></property>
        <!--项目名称-->
        <property name="SERVICE_NAME" value="xxxx-service"></property>
        <!--日志路径-->
        <property name="FILE_PATH" value="/var/logs"></property>
    </Properties>

    <!--先定义所有的appender-->
    <appenders>
        !--这个输出控制台的配置-->
        <console name="Console" target="SYSTEM_OUT">
            <!--控制台只输出level及以上级别的信息(onMatch),其他的直接拒绝(onMismatch)-->
            <ThresholdFilter level="debug" onMatch="ACCEPT" onMismatch="DENY"/>
            <!--输出日志的格式-->
            <PatternLayout charset="UTF-8" pattern="${LOG_PATTERN}"/>
        </console>
        <!-- 这个会打印出所有的info及以下级别的信息,每次大小超过size,则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩,作为存档-->
        <RandomAccessFile name="RandomFileInfo" fileName="${FILE_PATH}/${SERVICE_NAME}/info.log"
                     filePattern="${FILE_PATH}/${SERVICE_NAME}/${date:yyyy-MM}/info-%d{yyyy-MM-dd}-%i.log">
            <!--控制台只输出level及以上级别的信息(onMatch),其他的直接拒绝(onMismatch)-->
            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
            <PatternLayout charset="UTF-8" pattern="${LOG_PATTERN}"/>
            <Policies>
                <TimeBasedTriggeringPolicy/>
                <SizeBasedTriggeringPolicy size="20 MB"/>
            </Policies>
            <!-- DefaultRolloverStrategy属性如不设置,则默认为最多同一文件夹下7个文件,这里设置了20 -->
            <DefaultRolloverStrategy max="20"/>
        </RandomAccessFile>
        <RandomAccessFile name="RandomFileWarn" fileName="${FILE_PATH}/${SERVICE_NAME}/warn.log"
                     filePattern="${FILE_PATH}/${SERVICE_NAME}/${date:yyyy-MM}/warn-%d{yyyy-MM-dd}-%i.log">
            <ThresholdFilter level="warn" onMatch="ACCEPT" onMismatch="DENY"/>
            <PatternLayout charset="UTF-8" pattern="${LOG_PATTERN}"/>
            <Policies>
                <TimeBasedTriggeringPolicy/>
                <SizeBasedTriggeringPolicy size="20 MB"/>
            </Policies>
            <!-- DefaultRolloverStrategy属性如不设置,则默认为最多同一文件夹下7个文件,这里设置了20 -->
            <DefaultRolloverStrategy max="20"/>
        </RandomAccessFile>
        <RandomAccessFile name="RandomFileError" fileName="${FILE_PATH}/${SERVICE_NAME}/error.log"
                     filePattern="${FILE_PATH}/${SERVICE_NAME}/$${date:yyyy-MM}/error-%d{yyyy-MM-dd}-%i.log">
            <ThresholdFilter level="error" onMatch="ACCEPT" onMismatch="DENY"/>
            <PatternLayout charset="UTF-8" pattern="${LOG_PATTERN}"/>
            <Policies>
                <TimeBasedTriggeringPolicy/>
                <SizeBasedTriggeringPolicy size="20 MB"/>
            </Policies>
            <!-- DefaultRolloverStrategy属性如不设置,则默认为最多同一文件夹下7个文件,这里设置了20 -->
            <DefaultRolloverStrategy max="20"/>
        </RandomAccessFile>
    </appenders>
    <!--然后定义logger,只有定义了logger并引入的appender,appender才会生效-->
    <loggers>
        <!--打印Sql Debug日志-->
        <logger name="xxxxxxxxx.dao" level="debug"/>
        <root level="info">
            <appender-ref ref="Console"/>
            <appender-ref ref="RandomFileInfo"/>
            <appender-ref ref="RandomFileWarn"/>
            <appender-ref ref="RandomFileError"/>
        </root>
    </loggers>
</configuration>
2. 机器上增加filebeat服务
  1. 按照filebeat官网的quickstart安装
    https://www.elastic.co/guide/en/beats/filebeat/current/setup-repositories.html

  2. https://github.com/spujadas/elk-docker/tree/master/nginx-filebeat内的logstash-beats.crt 下载到本地,copy到/etc/filebeat/.

  3. 修改/etc/filebeat/路径下的filebeat.yml

filebeat.inputs:
- type: log
  enabled: true
  paths:
     - /var/logs/xxxxx-service/info.log #修改为对应服务的日志地址
  fields:
     type: xxxxx-service-dev #输出的index索引
- type: log
  enabled: true
  paths:
     - /var/logs/yyyyyy-service/info*.log
  fields:
     type: yyyyyy-service-dev
setup.template.settings:
  index.number_of_shards: 1
filebeat.config.modules:
  path: ${path.config}/modules.d/*.yml
  reload.enabled: false
output.logstash:
  hosts: ["logstash_ip:5044"]
  ssl.certificate_authorities: ["/etc/filebeat/logstash-beats.crt"]
processors:
  - add_host_metadata:
      when.not.contains.tags: forwarded
  - add_cloud_metadata: ~
  - add_docker_metadata: ~
  - add_kubernetes_metadata: ~
  1. 修改之前elk对应的/app/elk/logstash/11-nginx.conf,修改完毕后重启elk的容器
## 在filter内增加如下配置,根据log4j的日志格式进行解析
grok {
    match => {"message" => "%{DATA:level}\|%{DATA:datetime}\|%{DATA:trace_id}\|%{DATA:thread_id}\|%{DATA:method_name}\|%{DATA:msg}$"}
    remove_field => ["message"]
  }
  1. 执行命令
sudo systemctl enable filebeat
sudo systemctl restart filebeat
3. elk上增加index索引
  1. elk上增加index索引,与刚刚filebeat内配置的filebeat.inputs.fields.type相同,需逐个配置
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容