logstash如何收集k8s容器的前台日志

要收集Kubernetes容器的前台日志，可以使用Logstash结合Kubernetes的日志驱动程序来实现。下面是一个实现的步骤：

首先，确保你有一个运行Logstash的Kubernetes集群。你可以使用Helm来安装和管理Logstash。
创建一个Logstash配置文件，例如logstash.conf，其中定义了输入和输出插件。下面是一个示例配置文件：

input {
  container {
    id => "container_input"
    type => "kubernetes"
  }
}

output {
  elasticsearch {
    hosts => ["elasticsearch:9200"]
    index => "logs-%{+YYYY.MM.dd}"
  }
}

在这个配置中，我们使用container输入插件来收集容器的前台日志，并将其发送到Elasticsearch中。

创建一个Kubernetes的ConfigMap，将Logstash配置文件添加到其中：

apiVersion: v1
kind: ConfigMap
metadata:
  name: logstash-config
data:
  logstash.conf: |
    <内容为logstash.conf的配置文件>

创建一个Logstash的Deployment，使用ConfigMap挂载配置文件：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: logstash
spec:
  replicas: 1
  selector:
    matchLabels:
      app: logstash
  template:
    metadata:
      labels:
        app: logstash
    spec:
      containers:
        - name: logstash
          image: docker.elastic.co/logstash/logstash:7.12.1
          ports:
            - containerPort: 5044
          volumeMounts:
            - name: logstash-config
              mountPath: /usr/share/logstash/pipeline/logstash.conf
              subPath: logstash.conf
      volumes:
        - name: logstash-config
          configMap:
            name: logstash-config

在这个Deployment中，我们使用Logstash的官方Docker镜像，并将配置文件挂载到容器中的/usr/share/logstash/pipeline/logstash.conf路径。

创建一个Logstash的Service，用于将Kubernetes容器的日志流量转发到Logstash的Pod：

apiVersion: v1
kind: Service
metadata:
  name: logstash
spec:
  selector:
    app: logstash
  ports:
    - protocol: TCP
      port: 5044
      targetPort: 5044

部署这些配置到Kubernetes集群中：

kubectl apply -f logstash-config.yaml
kubectl apply -f logstash-deployment.yaml
kubectl apply -f logstash-service.yaml

完成以上步骤后，Logstash将开始收集Kubernetes容器的前台日志，并将它们发送到Elasticsearch中。你可以根据自己的需求进行进一步的日志处理和分析。