filter

in lib/fluent/plugin/filter_process_redfishalert.rb [26:50]


    def filter(tag, time, record)
      begin
      
      rmcSN = getMachineIdentifier(record["REMOTE_ADDR"])
      if tag == "redfish.alert"
        rgSN = getRackGroupIdentifier(record["REMOTE_ADDR"])
      end
      rescue SecurityError => se
        record["error"] = "Error calling redfish API: #{se.message}"
      end
      if @hardware == "Dell_PowerEdge_iDRAC"
        record["ProductID"] = rmcSN
        record["PowerState"] = getPowerState(record["REMOTE_ADDR"])
      elsif @hardware == "SUPERMICRO"
        record["ProductSerialNumber"] = rmcSN
        record["ChassisSerialNumber"] = rgSN
        record["PowerState"] = getPowerState(record["REMOTE_ADDR"])
      else
        record["RMCSerialNumber"] = rmcSN
        
        record["BaseChassisSerialNumber"] = rgSN
      end
      record
    end