support sprintf-formatting of column names in coerce_values

Author: chengshiwen

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 5.0.6
+  - Column names in coerce_values now supports sprintf formatting
+
 ## 5.0.5
   - Added clarifying information for `send_as_tags` config option [#80](https://github.com/logstash-plugins/logstash-output-influxdb/pull/80)
 

lib/logstash/outputs/influxdb.rb

@@ -74,6 +74,8 @@ class LogStash::Outputs::InfluxDB < LogStash::Outputs::Base
   #
   # currently supported datatypes are `integer` and `float`
   #
+  # supports sprintf-formatting in column names
+  #
   config :coerce_values, :validate => :hash, :default => {}
 
   # Automatically use fields from the event as the data points sent to Influxdb
@@ -155,7 +157,7 @@ def receive(event)
     time  = timestamp_at_precision(event.timestamp, @time_precision.to_sym)
     point = create_point_from_event(event)
     exclude_fields!(point)
-    coerce_values!(point)
+    coerce_values!(point, event)
 
     if point.has_key?('time')
       unless @allow_time_override
@@ -217,8 +219,9 @@ def create_point_from_event(event)
   # foreknowledge of what's in the data point, which is less than ideal. An 
   # alternative is to use a `code` filter and manipulate the individual point's
   # data before sending to the output pipeline
-  def coerce_values!(event_data)
+  def coerce_values!(event_data, event)
     @coerce_values.each do |column, value_type|
+      column = event.sprintf(column)
       if event_data.has_key?(column)
         begin
           @logger.debug? and @logger.debug("Converting column #{column} to type #{value_type}: Current value: #{event_data[column]}")

logstash-output-influxdb.gemspec

@@ -1,6 +1,6 @@
 Gem::Specification.new do |s|
   s.name            = 'logstash-output-influxdb'
-  s.version         = '5.0.5'
+  s.version         = '5.0.6'
   s.licenses        = ['Apache License (2.0)']
   s.summary         = "Writes metrics to InfluxDB"
   s.description     = "This gem is a Logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/logstash-plugin install gemname. This gem is not a stand-alone program"