如何在Fluentd配置的Ruby表达式中访问container_name变量

当然可行！你遇到的问题是因为在Fluentd的Ruby插值上下文里，日志记录的字段并不是直接以变量名暴露的，而是存储在record这个哈希对象中。直接写container_name会被当作未定义的局部变量，所以会报错。

正确的配置方式 #

要访问日志里的container_name字段，你需要通过record['container_name']来引用它。同时，为了避免字段不存在或者匹配失败导致Fluentd崩溃，最好加上容错处理：

<match container.**>
  @type cloudwatch_logs
  region us-west-2
  # 安全提取匹配的部分，带多层兜底
  log_group_name "#{record['container_name']&.match(/\w+/)&.[](0) || record['container_name'] || 'default-log-group'}"
  log_stream_name "#{File.open('/etc/machine-id').read.strip()}"
  auto_create_stream true
  retention_in_days 7
</match>

配置解释 #

• record['container_name']：获取日志记录中的container_name字段值
• &.：Ruby的安全导航操作符，当左边的值为nil时，会直接返回nil而不是抛出方法调用错误，避免字段不存在时崩溃
• match(/\w+/)&.[](0)：匹配字符串中的第一个连续字母数字序列，同样用安全导航避免匹配失败时出错
• || record['container_name']：如果匹配不到内容，就回退使用原始的container_name
• || 'default-log-group'：最后兜底的默认日志组名，防止前面所有情况都为nil

兼容旧Ruby版本的写法 #

如果你的Fluentd使用的Ruby版本低于2.3（不支持&.操作符），可以换成条件判断的写法：

<match container.**>
  @type cloudwatch_logs
  region us-west-2
  log_group_name "#{
    if record['container_name'] && match_result = record['container_name'].match(/\w+/)
      match_result[0]
    else
      record['container_name'] || 'default-log-group'
    end
  }"
  log_stream_name "#{File.open('/etc/machine-id').read.strip()}"
  auto_create_stream true
  retention_in_days 7
</match>

额外注意事项 #

• 确保你的日志记录中确实存在container_name字段，可以先用stdout插件测试输出，确认字段存在
• 如果你使用的是docker或containerd相关的输入插件，要确认插件已经正确解析并添加了container_name字段到日志记录中

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