github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

- exclude @timestamp and @version if 'fields_are_metrics' is set.

Browse source
This commit is contained in:
Jordan Sissel 2013-08-24 21:39:35 -07:00
parent d57faf5f99
commit f303105308
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
lib/logstash/outputs/graphite.rb
View file

@ -12,6 +12,8 @@ class LogStash::Outputs::Graphite < LogStash::Outputs::Base
config_name "graphite" config_name "graphite"
milestone 2 milestone 2
EXCLUDE_ALWAYS = [ "@timestamp", "@version" ]
DEFAULT_METRICS_FORMAT = "*" DEFAULT_METRICS_FORMAT = "*"
METRIC_PLACEHOLDER = "*" METRIC_PLACEHOLDER = "*"
@ -102,6 +104,7 @@ class LogStash::Outputs::Graphite < LogStash::Outputs::Base
if @fields_are_metrics if @fields_are_metrics
@logger.debug("got metrics event", :metrics => event.to_hash) @logger.debug("got metrics event", :metrics => event.to_hash)
event.to_hash.each do |metric,value| event.to_hash.each do |metric,value|
next if EXCLUDE_ALWAYS.include?(metric)
next unless @include_metrics.empty? || @include_metrics.any? { |regexp| metric.match(regexp) } next unless @include_metrics.empty? || @include_metrics.any? { |regexp| metric.match(regexp) }
next if @exclude_metrics.any? {|regexp| metric.match(regexp)} next if @exclude_metrics.any? {|regexp| metric.match(regexp)}
messages << "#{construct_metric_name(metric)} #{event.sprintf(value.to_s).to_f} #{timestamp}" messages << "#{construct_metric_name(metric)} #{event.sprintf(value.to_s).to_f} #{timestamp}"