K8s中运行的Fluentbit如何将两个字段拼接为host字段值？

该需求完全可以实现。Fluent Bit 原生的 modify 过滤器不支持多字段/变量拼接操作，你可以替换为 record_modifier 过滤器或者 Lua 过滤器来完成字段拼接逻辑，以下是两种可行的配置方案：

方案1：使用 record_modifier 过滤器（配置更简单） #

record_modifier 是 Fluent Bit 内置的字段处理插件，支持直接引用已有的日志字段和环境变量进行拼接，适合这类简单的拼接场景。

注意：请确保你已经正确配置了 Kubernetes 过滤器，且顺序在当前过滤器之前，保证 kubernetes_namespace_name 字段已被注入到日志记录中。

配置示例：

# 替换你原有的modify过滤器即可
[FILTER]
    Name record_modifier
    Match *
    # 可自行调整拼接分隔符，示例使用下划线分隔集群名和命名空间名
    Record host ${K8S_CLUSTER_NAME}_$kubernetes_namespace_name

方案2：使用 Lua 过滤器（灵活性更高） #

如果后续还有更复杂的字段处理逻辑，可以选择 Lua 过滤器实现：

[FILTER]
    Name lua
    Match *
    call concat_host
    code function concat_host(tag, timestamp, record) record["host"] = os.getenv("K8S_CLUSTER_NAME") .. "_" .. record["kubernetes_namespace_name"] return 2, timestamp, record end

验证注意事项 #

• 配置生效后可以先打印 stdout 输出，检查 host 字段拼接结果是否符合预期
• 如果出现 kubernetes_namespace_name 为空的情况，优先检查 Kubernetes 过滤器的配置和加载顺序

内容的提问来源于stack exchange，提问作者Sai