THIS CLASS MUST BE THREAD-SAFE
# File lib/fluent/plugin/filter_record_transformer.rb, line 177 def initialize(params) @log = params[:log] @auto_typecast = params[:auto_typecast] end
Expand string with placeholders
@param [String] str @param [Boolean] force_stringify the value must be string, used for hash key
# File lib/fluent/plugin/filter_record_transformer.rb, line 219 def expand(str, placeholders, force_stringify = false) if @auto_typecast && !force_stringify single_placeholder_matched = str.match(/\A(\${[^}]+}|__[A-Z_]+__)\z/) if single_placeholder_matched log_if_unknown_placeholder($1, placeholders) return placeholders[single_placeholder_matched[1]] end end str.gsub(/(\${[^}]+}|__[A-Z_]+__)/) { log_if_unknown_placeholder($1, placeholders) placeholders[$1] } end
# File lib/fluent/plugin/filter_record_transformer.rb, line 190 def prepare_placeholders(placeholder_values) placeholders = {} placeholder_values.each do |key, value| if value.kind_of?(Array) # tag_parts, etc size = value.size value.each_with_index do |v, idx| placeholders.store("${#{key}[#{idx}]}", v) placeholders.store("${#{key}[#{idx-size}]}", v) # support [-1] end elsif value.kind_of?(Hash) # record, etc value.each do |k, v| unless placeholder_values.has_key?(k) # prevent overwriting reserved keys such as tag placeholders.store("${#{k}}", v) # foo end placeholders.store(%Q[${#{key}["#{k}"]}], v) # record["foo"] end else # string, interger, float, and others? placeholders.store("${#{key}}", value) end end placeholders end
# File lib/fluent/plugin/filter_record_transformer.rb, line 186 def preprocess_map(value, force_stringify = false) value end
# File lib/fluent/plugin/filter_record_transformer.rb, line 182 def time_value(time) Time.at(time).to_s end
# File lib/fluent/plugin/filter_record_transformer.rb, line 235 def log_if_unknown_placeholder(placeholder, placeholders) unless placeholders.include?(placeholder) log.warn "unknown placeholder `#{placeholder}` found" end end