用于检查流利过滤器中的字符串的 Ruby 表达式

Question

如果日志字段包含特定字符串，我需要创建一个新字段“状态”。我在fluentd中尝试了下面的代码，但这不起作用。我需要检查日志字段是否包含字符串“错误：”，那么新字段状态应该有错误，否则如果没问题，应该没问题。

<filter **>
  @type record_transformer
  enable_ruby true
  <record>
    status "${\
      if record['log'].downcase.include? 'error:'
        puts 'error'
      elsif record['log'].downcase.include? 'ok:'
        puts 'ok'
      end}"
  </record>
</filter>

我们可以使用正则表达式来做到这一点吗？

我也尝试过使用扫描。

<filter **>
  @type record_transformer
  enable_ruby true  
  <record>
   status ${record["log"].scan(/^.* ([[:<:]]error[[:>:]]|[[:<:]]ok[[:>:]]):.*$/i).first.compact} 
  </record>  
</filter>

Answer 1

除了现在阅读他们的文档之外，我对 fluentd 没有太多经验。但是你能检查一下下面的代码sn-p吗？

<filter **>
  @type record_transformer
  enable_ruby true
  <record>
    status "${record['log'].downcase.include?('error:') ? 'error' : (record['log'].downcase.include?('ok:') ? 'ok' : '')}"
  </record>
</filter>

我怀疑您的 sn-p 上的 puts 是否有效。所以我有点改变了代码。如果这是您正在寻找的东西，请告诉我。