如何使用 fluentd 收集 pod 日志并将日志发送到 elasticsearch?

How can I collect the pod logs using fluentd and send the logs to elasticsearch?

我正在尝试使用 fluentd 将我们使用以下命令看到的标准输出日志推送到弹性搜索。我不确定我能做什么?

Kubectl logs -f <podname>

这显示了通过 Java 应用程序打印的所有 SYSOUT 日志。 我希望这些日志在 elasticsearch 中可用。

你检查过this了吗?

从上面link

  1. 获得流利的 deamonset
  2. 像下面那样调整 deamonset 清单文件(如 link 中所述)
apiVersion: extensions/v1beta1
kind: DaemonSet
metadata:
  name: fluentd
  namespace: kube-system
  ...
spec:
    ...
    spec:
      containers:
      - name: fluentd
        image: quay.io/fluent/fluentd-kubernetes-daemonset
        env:
          - name:  FLUENT_ELASTICSEARCH_HOST
            value: "elasticsearch-logging"
          - name:  FLUENT_ELASTICSEARCH_PORT
            value: "9200"
        ...