Rancher 2.6 全新 Logging 快速入门

作者简介
袁振，SUSE Rancher 技术支持经理，负责订阅客户售后技术支持团队，为订阅客户提供技术支持服务。2016 年开始接触容器、Kubernetes 技术，对自动化运维、Devops、Kubernetes、prometheus 和其他云原生相关技术具有较深入的研究，对 SRE 运维体系建设、SRE 运维系统架构设计有着丰富的实践经验。

背景概述

在 SUSE Rancher 2.5 以前，日志收集的架构是使用 Fluentd 收集指定目录日志或者容器标准输出流后，再通过 UI 日志功能页面的配置发送到指定的后端。如 Elasticsearch、splunk、kafka、syslog、fluentd 等常见的后端工具，可以自动化地收集 kubernetes 集群和运行于集群之上的工作负载日志。这种方式无疑是非常简单、易用、方便的，但是随着用户对云原生理解的加深，对业务日志分析颗粒度要求的提高，之前的日志收集方式有些太过死板，灵活性非常差，已经无法满足对日志收集具有更高要求的用户了。

于是从 SUSE Rancher 2.5 版本开始，BanzaiCloud 公司的开源产品 Logging Operator 成为了新一代 SUSE Rancher 容器云平台日志采集功能的组成组件。SUSE Rancher 2.5 版本作为新日志组件的过渡版本，保留了老版本的日志收集方式，并将全新的 Logging Operator 作为实验性功能使用；SUSE Rancher 2.6 版本则已经完全使用了 Logging Operator 作为日志收集工具。

本文将由浅到深地探索全新的 SUSE Rancher 2.6 Logging Operator 功能和它的使用方式。

什么是Logging Operator

Logging Operator 是 BanzaiCloud 基于云原生场景的开源日志采集方案，SUSE Rancher 2.6 版本在整合了该产品之后，将会在用户的操作下自动部署 Logging Operator 并自动配置 kuberletes logging pipeline。

Logging Operator 架构

以上是 Logging Operator 官方架构图。Logging Operator 使用 CRD 的方式决定了日志采集、规则路由、输出这三个阶段的配置，它使用 Daemonset 在集群节点上部署 Fluentbit 组件，使用 StatefulSet 部署 Fluentd 组件。首先由 Fluentbit 组件进行日志收集并初步处理之后，发送到 Fluentd 组件进行进一步的解析处理，最终由 Fluentd 组件发送到不同的后端工具上。

Logging Operator CRD

上文提到，Logging Operator 使用 CRD 的方式决定了日志采集、规则路由、输出这三个阶段的配置，其使用的 CRD 主要有以下5种类型：

  • logging：用于定义一个日志采集端 (FleuntBit) 和传输端 (Fleuntd) 服务的基础配置，在 SUSE Rancher 2.6 版本中，已经由 Rancher 自动化部署完成；
  • flow：用于定义一个 namespaces (命名空间)级别的日志过滤、解析和路由等规则;
  • clusterflow：用于定义一个集群级别的日志过滤、解析和路由等规则;
  • output：用于定义 namespace (命名空间)级别的日志的输出和参数，它只能被同命名空间内的 flow 关联；
  • clusteroutput：用于定义集群级别的日志输出和参数，它能把被其他命名空间内的 flow 关联。

以上 5 个 CRD 类型非常重要，决定了一个 Kubernetes 集群内每个命名空间甚至每个容器的日志输出到哪里。

启用 SUSE Rancher 2.6 Logging

SUSE Rancher 2.6 成功创建下游 Kubernetes 集群后，可以在集群工具页面找到 Logging 工具的部署入口，如下图所示：

点击安装按钮后，选择组件安装的项目，一般选择为 System 项目，在该项目中运行与集群运行相关的组件；点击下一步后，UI 会要求输入配置 Docker 根目录和 System Log Path；

  • 注意：如果底层容器运行时 (Runtime)为 Docker，默认为：/var/lib/docker。如果自定义过，请填写正确的 Docker Root Dir 目录，可以通过 docker info ｜ grep Docker Root Dir 命令查看；
  • 注意：System Log Path 用于收集主机操作系统 Journal 日志，如果填写错误会导致主机操作系统日志无法收集，确认该路径的方法如下：
## 确认Journal Log Path检查方式，在节点上执行以下命令

cat /etc/systemd/journald.conf | grep -E ^\#?Storage | cut -d"=" -f2

1、如果返回persistent，则systemdLogPath应该是/var/log/journal；
2、如果返回volatile，则systemdLogPath应该是/run/log/journal；
3、如果返回auto，则检查/var/log/journal是否存在；
 - 如果/var/log/journal存在，则使用/var/log/journal；
 - 如果/var/log/journal不存在，则使用/run/log/journal；

输入正确的 Docker 根目录和 systemdLogPath 后，点击安装，SUSE Rancher 2.6 会自动部署 Logging Operator

执行以下命令检查部署是否成功

kubectl get pod -n cattle-logging-system

NAME                                           READY   STATUS      RESTARTS   AGE
rancher-logging-96b68cc4b-vqxnd                1/1     Running     0          9m54s
rancher-logging-fluentbit-cntgb                1/1     Running     0          69s
rancher-logging-fluentbit-hwmdx                1/1     Running     0          71s
rancher-logging-fluentbit-nw7rw                1/1     Running     0          71s
rancher-logging-fluentd-0                      2/2     Running     0          9m34s
rancher-logging-fluentd-configcheck-ac2d4553   0/1     Completed   0          9m48s

部署完成后，SUSE Rancher 2.6 集群 UI 上多了一个日志选项卡，可以由此配置上文提到的 flow、clusterflow、output、clusteroutput 资源对象，从而完成整个日志采集、过滤路由、输出的全流程配置。

从 SUSE Rancher 2.6 UI 上直接进行日志采集流程的配置固然方便，但是对 Logging Operator 比较熟悉的“大神”或者经常使用的“大佬”，可以使用 SUSE Rancher 2.6 UI 直接进行配置，从而完成整个日志采集、过滤路由、输出的全流程配置；对于刚刚升级为 SUSE Rancher 2.6 或者刚刚接触 Logging Operator 的“小白”朋友们，咱们还是不要着急上手了，深入浅出、循序渐进，继续往下读完，看看这些 CRD 是怎么配置和工作的。

Flow 和 ClusterFlow

从本文最开始的架构流程图可以看出，整个 Logging Operator 最为核心的两个概念就是 flow 和 output，其中 flow 就是用来处理日志流的，决定了从哪里采集、怎么过滤、如何路由分发；clusterflow 具有相同的功能，是个全局 flow。

在了解 flow CRD 的定义之前，先用一个简单的 flow 示例来进行以下分析：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "elasticsearch-output" ## 定义Output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - select:
        labels: ## 使用标签匹配采集日志
          app: nginx

这个 flow 的意思是，只会采集 default 命名空间内标签 app=nginx 的容器日志，采集日志后按照 nginx 格式进行解析，并且将这个日志流的 tag 在 fluentd 最终汇总时重定向为

${namespace_name}.${pod_name}.${container_name}

格式。

match

上面的例子里有一个非常重要的定义 match，它定义了哪些日志需要被采集，根据 Logging Operato 官方文档给出的说明，当前可以使用的字段有以下几种：

  • namespaces 使用命名空间进行匹配；
  • labels 使用标签进行匹配；
  • hosts 使用主机进行匹配；
  • container_names 使用容器名称进行匹配。

设想一个场景，在一个 Kubernetes 集群中，我们只想不采集某些容器的日志，使用匹配需要写无数个匹配规则，这显然是不合理的，所以官方给了 exclude 字段，使用排除。例子如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "es-output" ## 定义Output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - exclude: ##排除所有标签是app:nginx的容器
        labels:  
          app: nginx

上面这个例子会排除采集所有标签是 app:nginx 的容器日志；exclude 和 select 可以同时存在，也可以有多个 exclude 和 select 存在，更灵活的定义需要采集哪些容器日志。

除了 flow 以外还有 clusterflow。设想一个场景，我们有 N 个 namespaces，但是我们需要采集除了某一个 namespaces 以外的所有 namespaces 的容器日志。这个时候，每个 namespaces 设定一条 flow 明显是不合理的，这就需要使用 clusterflow 设置规则来进行采集，示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: ClusterFlow  ##定义为clusterflow
metadata:
  name: default-cluster-flow
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "es-output" ## 定义Output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - exclude: ##排除不想要采集的namespaces
        namespaces:  
          - default
          - kube-system

上面的示例表示这是一个 cluster 级别的 flow，根据 match 定义，将采集除了 default 和 kube-system 命名空间以外的所有命名空间日志；与 flow 相同的是， clusterflow 中的 match 定义的 exclude 和 select 可以同时存在，也可以有多个 exclude 和 select 同时存在，从而制定更细致的规则。

filters

filters 是 Logging Operator 中的日志处理插件，目前官方支持的日志处理插件如下：

  • Concat: 用于 fluentd 处理日志多行的插件;
  • Dedot: 处理带.的字段替换插件，通常用于输出到 elaticsearch 前的字段转化;
  • Exception Detector: Exception 日志捕获器，支持 java, js, csharp, python, go, ruby, php;
  • Enhance K8s Metadata: banzaicloud 开发的 k8s 扩展元数据;
  • Geo IP: fluentd 的 GeoIP 地址库;
  • Grep: fluentd 的 grep 过滤器;
  • Parser: fluentd 的 Parser 解析器,parse 支持 apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none;
  • Prometheus: Prometheus 插件，可用于对日志做计数;
  • Record Modifier: fluentd 字段修改插件;
  • Record Transformer: Mutates/transforms incoming event streams;
  • Stdout: 标准输出插件;
  • SumoLogic: Sumo Logic 公司的日志处理插件;
  • Tag Normaliser: fluentd 中的 tag 修改器。

Parser 插件

Parser 插件最常用、最简单，支持解析持 apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none 格式的日志。如果需要解析 nginx 的日志，可以直接用 Parser 插件进行处理，示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-nginx-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理

如果需要解析 json 格式的日志，示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: 
          type: json ##解析为json格式
          time_key: time ##自定义key
          time_format: "%Y-%m-%dT%H:%M:%S"

我们可以在Parser插件指定多种类型的日志解析格式，示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse:
          type: multi_format
          patterns:
            - format: nginx ##解析Nginx格式
            - format: json  ##解析json格式
              time_key: time
              time_format: "%Y-%m-%dT%H:%M:%S"

从上面的几个例子可以看出来，处理解析日志格式是非常灵活的，可以搭配不同的插件和解析格式来应对不同类型的日志格式。

介绍完常用的 Parser 插件后，再给大家介绍一个以往可能都没有遇到过或者配置起来比较复杂的场景：如果需要统计业务日志在一定时间段内打印了多少总数，用于分析业务运营指标，怎么办呢？可能大家第一时间想到的是，反正都已经处理完丢到类似 Kibana 的工具上了，直接过滤一下不就出数据了？这个方法是可以的，但是假设一下，想要通过日志条目数量持续分析业务运营指标怎么办？接下来分享另外一个插件。

Prometheus 插件

Prometheus 作为云原生时代的监控利器，强大的时序型数据库，配合 PromQL 和 Grafana 还有众多的Exporter，基本可以监控我们需要的任何指标；Logging Operator 中也引入了 Prometheus 插件，用于统计暴露收集的指定日志条目。示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - prometheus: ##Pormetheus插件
        metrics:
          - desc: The total number of nginx in log. ##指标说明
            name: nginx_log_total_counter  ##指标名称
            type: counter ##指标Prometheus类型
            labels: ## 指标标签
              app: nginx
        labels: ##指标标签
          host: ${hostname}
          tag: ${tag}
          namespace: $.kubernetes.namespaces
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "es-output" ## 定义Output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - select:
        labels: ## 使用标签匹配采集日志
          app: nginx

以上例子使用了 Parser 插件对 Nginx 日志进行处理，使用了 Prometheus 插件对输出的 Nginx 日志进行统计。Prometheus 插件主要有以下几个字段：

  • desc: 对该指标的描述；

  • name: 指标的名称；

  • type: 指标的 Prometheus 数据类型(了解更多请参考 Prometheus 数据类型文档)；

  • labels: 指标的标签(了解更多请参考 Prometheus Label 文档)。

通过上面这个 Flow 就可以统计总共处理了多少行 Nginx 的日志，并使用 Prometheus 暴露 counter 类型指标以做监控分析。

小结

通过以上两个插件的使用示例可以看出 Logging Operator 的灵活、强大之处，此外，您还可以配合其他众多的插件，灵活地完成对日志采集处理的需求。关于更多 Logging Operator 的 filter 支持的插件说明，请查看 https://banzaicloud.com/docs/one-eye/logging-operator/configuration/plugins/filters/

Output 和 ClusterOutput

Output 和 ClusterOutput 两个 CRD 定义了处理完成的日志应该输出到哪个地方。与 flow 和 clusterflow 相同的是，output 同样是 namespaces 级别的，它只能被同命名空间下的 flow 引用；clusterflow 是集群级别的，可以被不同命名空间的 flow 和 clusterflow 引用。

Output

Output 定义了日志的输出方式，目前 Logging Operator 支持输出插件如下：

  • Alibaba Cloud
  • Amazon CloudWatch
  • Amazon Elasticsearch
  • Amzon Kinesis
  • Amazon S3
  • Amzon Storage
  • Buffer
  • Datadog
  • Elasticsearch
  • File
  • Format
  • Format rfc5424
  • Forward
  • GELF
  • Goole Cloud Storage
  • Grafana Loki
  • Http
  • Kafka
  • LogDNA
  • LogZ
  • NewRelic
  • Splunk
  • SumoLogic
  • Syslog

可以看到 Logging Operator 支持输出的插件还是非常丰富的，基本上涵盖了使用场景中的工具。下面我们将以常用的两种插件 Kafka 和 Elasticsearch 进行举例，配置 Output CRD。

Output-Kafka

apiVersion: logging.banzaicloud.io/v1beta1
kind: Output  
metadata:
  name: kafka-output
spec:
  kafka: 
    brokers: kafka-headless.kafka.svc.cluster.local:29092 ##kafka地址
    default_topic: topic
    topic_key: kafka-output ##kafka topic名称；
    sasl_over_ssl: false ##是否使用ssl
    format:
      type: json  ##类型
    buffer: ##发送buff配置
      tags: topic
      timekey: 1m
      timekey_wait: 30s
      timekey_use_utc: true

在上面这个简单例子中，我们定义了一个输出到 kafka 的 output CRD，可以看到几个关键配置，kafka 的地址、topic 的名称、是否使用 ssl；下面的 buffer指发送 buffer 配置，这样一个发送到 kafka 的 output CRD 就完成了。Buff 配置也可以根据实际情况进行调整。

Output-Elasticsearch

apiVersion: logging.banzaicloud.io/v1beta1
kind: Output  
metadata:
  name: elasticsearch-output
spec:
  elasticsearch:
    host: elasticsearch-elasticsearch-cluster.default.svc.cluster.local
    port: 9200
    scheme: https
    ssl_verify: false
    ssl_version: TLSv1_2
    buffer:
      timekey: 1m
      timekey_wait: 30s
      timekey_use_utc: true

在上面这个简单例子中，我们定义了一个输出到 elasticsearch 的 output CRD，其实和 kafka的 output 配置类似，需要定义 elasticsearch 的地址、端口、是否需要 ssl 认证；buffer 配置定义了发送时的 buff 配置。

关于更多配置项，查看文档：https://banzaicloud.com/docs/one-eye/logging-operator/configuration/plugins/outputs/

flow 和 output 相关联

在定义好了 flow 和 output 之后，需要在 flow 定义 localOutputRefs 来与 output 进行关联，以进行日志的发送处理。示例如下：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "elasticsearch-output" ## 输出到elasticsearch-output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - select:
        labels: ## 使用标签匹配采集日志
          app: nginx

在上面这个例子中，localOutputRefs 配置了 elasticsearch-output，这样就与我们刚刚定义的名称为 elasticsearch-output 的 output 进行了关联，日志就可以从指定的 output 进行输出。值得一提的是，Logging Operator 充分考虑了相同日志需要输出到不同地点的需求。比如下面这个例子，就可以将日志同时输出到 kafka 和 elasticsearch：

apiVersion: logging.banzaicloud.io/v1beta1
kind: Flow  
metadata:
  name: default-flow
  namespace: default ##定义收集日志的命名空间
spec:
  filters:  ##定义过滤器，一个flow可以定义一个或者多个
    - parser:
        remove_key_name_field: true
        parse: ##parse支持apache2, apache_error, nginx, syslog, csv, tsv, ltsv, json, multiline, none, logfmt类型解析
          type: nginx ##采集日志按照Nginx格式进行处理
    - tag_normaliser:
        format: ${namespace_name}.${pod_name}.${container_name} ##在fluentd里面使用${namespace_name}.${pod_name}.${container_name}的格式
  localOutputRefs:
    - "elasticsearch-output" ## 输出到elasticsearch-output
    - "kafka-output" ##输出到kafka-output
  match:  ## Kubernetes标签来定义哪些日志需要被采集 
    - select:
        labels: ## 使用标签匹配采集日志
          app: nginx

小结

上文介绍的 flow、clusterflow 和 output、clusteroptput 功能都是灵活而强大的。在 SUSE Rancher 2.6 版本部署完 Logging 后，可以通过 yaml 编写 CRD 并直接应用到集群中，也可以直接在 SUSE Rancher UI 上进行配置。下一章将会介绍如何在 SUSE Rancher UI 上对 flow 和 output 进行配置。

在 SUSE Rancher UI 上对 flow 和 output 进行配置

本章节内容将会描述在 SUSE Rancher UI 上进行日志采集配置。

创建 outputs/clusteroutputs

在 SUSE Rancher UI 上配置首先需要创建一个 flow 或者 clusterflow，进入日志页面选择 outputs/clusteroutputs，选择将要发送的后端工具，示例中以 es 为例，配置索引名称、主机地址、端口、outputs 名称，如果有 https 或者 ssl 需要先创建 secrets。

创建完成后的 CRD yaml 如下：

apiVersion: logging.banzaicloud.io/v1beta1kind: Outputmetadata:  name: rancher26-es-output  namespace: defaultspec:  elasticsearch:    buffer:      timekey: 1m      timekey_use_utc: true      timekey_wait: 30s    host: 172.16.0.14    index_name: rancher26    port: 9200    scheme: http

创建 flow/clusterflow

Outputs 创建完成之后，开始创建 flow/clusterflow 规则：进入日志页面选择 flows/clusterflows，点击创建，进行 flow 配置，示例中将采集标签为 app:nginx 的容器日志：

  • 输入容器标签匹配规则、名称；如果有不想采集的主机或者容器，也可以进行选择；页面上也可以添加多个标签匹配规则；
  • 配置输出规则，这里选择我们刚刚创建的 outputs，这里可以选择多个 outputs 和 clusteroutput，也可以同时选择 output 和 clusteroptput；
  • 配置过滤规则，这里我们收集的是 nginx 日志，所以使用 parser 插件，自动格式化 nginx 规则；

创建完成后的 CRD yaml 如下：

apiVersion: logging.banzaicloud.io/v1beta1kind: Flowmetadata:  name: nginx-flow  namespace: default  fields:    - nginx-flowspec:  filters:    - parser:        parse:          type: nginx        remove_key_name_field: true  localOutputRefs:    - rancher26-es-output  match:    - select:        labels:          app: nginx

验证

配置完成后，如果集群中有符合标签要求的容器，就会自动采集并发送到 es；

  • 通过查看 fluentd 的配置，可以查看 outputs 是否生效
## 进入rancher-logging-fluentd-0 Pod命令行
cat fluentd/app-config/fluentd.conf
  <match **>
    @type elasticsearch
    @id flow:default:nginx-flow:output:default:rancher26-es-output
    exception_backup true
    fail_on_putting_template_retry_exceed true
    host 172.16.0.14
    index_name rancher26
    port 9200
    reload_connections true
    scheme http
    ssl_verify true
    utc_index true
    verify_es_version_at_startup true
    <buffer tag,time>
      @type file
      chunk_limit_size 8MB
      path /buffers/flow:default:nginx-flow:output:default:rancher26-es-output.*.buffer
      retry_forever true
      timekey 1m
      timekey_use_utc true
      timekey_wait 30s
    </buffer>
  </match>
  • 查看 elasticsearch 中的索引
  • 查看 kibana 中的日志详情

总结

至此，SUSE Rancher 2.6 全新的 Logging Operator 开箱使用就已经全部结束了。对比之前的日志收集功能，的确强大了不少，配置非常灵活，可以自定义多种过滤器，甚至使用 Prometheus 暴露自定义指标进行业务运营分析等内容。但是与之前只需要输入目标端地址就能使用的场景相对比，Logging Operator 确实也增加了一定的学习成本，建议“小白”朋友还是从零开始学习，搞清楚整体的运行架构和逻辑，这样有助于故障发生时的定位排查。

一些 Tips

  • 整体架构是由 Daemonst 类型的 fluentbit 组件进行日志采集，fluentbit 组件日志中会有日志文件的打印输出，当发现某些日志未被采集的时候，可以查看 fluentbit 组件的日志是否发现了这些日志；

  • Fluentd 组件负责汇总、处理、发送，当发现目标端没有收到日志，比如说 ES 没有创建索引的时候，可以看看 Fluentd 组件的日志。需要注意的是，截止文章发表时，Fluentd 的日志没有打印在标准输出中，需要进入 Pod 内执行命令查看：

tail -f fluentd/log/out

  • 无论是 UI 还是 CRD 的 flow/outputs 配置，最终都会转化为 fluentbit 和 Fluentd 的配置，如果对这两个组件比较熟悉，出现异常的时候可以进入 Pod 中查看具体生效的配置是否正确；

  • 由于过滤器的存在，错误的过滤、匹配的条件可能会导致日志无法发送出去，这个时候需要检查 flow 中配置的规则情况。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,530评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 86,403评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,120评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,770评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,758评论 5赞 367
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,649评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,021评论 3赞 398
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,675评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,931评论 1赞 299
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,751评论 1赞 330
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,410评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,004评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,969评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,042评论 2赞 350
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,493评论 2赞 343

推荐阅读更多精彩内容