lib/logstash/web/lib/elasticsearch.rb in logstash-lite-0.2.20101119183130 vs lib/logstash/web/lib/elasticsearch.rb in logstash-lite-0.2.20101120021802
- old
+ new
@@ -44,11 +44,12 @@
#headers req.response_header
data = JSON.parse(req.response)
data["duration"] = Time.now - start_time
# TODO(sissel): Plugin-ify this (Search filters!)
- require "digest/md5"
- data["hits"]["hits"].each do |hit|
+ #require "digest/md5"
+ #data["hits"]["hits"].each do |hit|
+ [].each do |hit|
event = LogStash::Event.new(hit["_source"])
event.to_hash.each do |key, value|
next unless value.is_a?(String)
value.gsub!(/[^ ]+\.loggly\.net/) { |match| "loggly-" + Digest::MD5.hexdigest(match)[0..6] + ".example.com"}
end