Fluentd 配置中环境变量的实战用法

核心语法一行："#{ENV['ES_HOST']}"——Fluentd 加载配置时执行 Ruby 表达式完成替换。掌握它就掌握了配置与密钥分离的关键手段。

完整示例

<source>
  @type forward
  port "#{ENV['FLUENT_PORT'] || '24224'}"
</source>

<match **>
  @type elasticsearch
  host "#{ENV.fetch('ES_HOST', 'localhost')}"
  user "#{ENV['ES_USER']}"
  password "#{ENV['ES_PASSWORD']}"
</match>

注意 ENV.fetch('ES_HOST', 'localhost') 与 ENV['ES_HOST'] || 'localhost' 在缺失时均使用默认值；空字符串对两者都不会触发默认值。必填变量可用不带默认值的 ENV.fetch。

三种环境的注入方式

Systemd：

[Service]
Environment="ES_HOST=es.internal"
EnvironmentFile=/etc/fluentd/secrets.env

Docker：

docker run -e ES_HOST=es.internal -e ES_PASSWORD="$(cat /run/secrets/es_pw)" fluentd

Kubernetes：

env:
  - name: ES_PASSWORD
    valueFrom:
      secretKeyRef: {name: es-secret, key: password}

排错技巧

变量替换失败最常见的是未 export 或进程环境隔离——用 fluentd --dry-run -c fluent.conf 预检，仅检查变量是否存在，不输出密码等值；dry-run 不验证最终投递。

常见问题（FAQ）

Q：数组/列表配置能用变量吗？ 插值结果会进入配置字符串，再由具体插件按参数类型解析；不能保证 Ruby 数组字符串就是插件要求的列表格式，需按该插件文档编码并验证。

Q：改环境变量后需要重启吗？ 需要——变量在配置加载时替换，reload 即使重新解析配置，也只看到进程已有的环境，不会继承另一个 shell 新 export 的值；服务环境变化通常需重启进程。