github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #625 from jdve/date-overwrite

Browse source 
filters: date: add target option
This commit is contained in:
Nick Ethier 2013-09-23 11:25:57 -07:00
commit bb6a4f9a7e
1 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
lib/logstash/filters/date.rb
View file

@ -79,6 +79,10 @@ class LogStash::Filters::Date < LogStash::Filters::Base
# #
config :match, :validate => :array, :default => [] config :match, :validate => :array, :default => []
# Store the matching timestamp into the given target field. If not provided,
# default to updating the @timestamp field of the event.
config :target, :validate => :string, :default => "@timestamp"
# LOGSTASH-34 # LOGSTASH-34
DATEPATTERNS = %w{ y d H m s S } DATEPATTERNS = %w{ y d H m s S }
@ -208,12 +212,13 @@ class LogStash::Filters::Date < LogStash::Filters::Base
time = time.withZone(UTC) time = time.withZone(UTC)
# Convert joda DateTime to a ruby Time # Convert joda DateTime to a ruby Time
event["@timestamp"] = Time.utc( event[@target] = Time.utc(
time.getYear, time.getMonthOfYear, time.getDayOfMonth, time.getYear, time.getMonthOfYear, time.getDayOfMonth,
time.getHourOfDay, time.getMinuteOfHour, time.getSecondOfMinute, time.getHourOfDay, time.getMinuteOfHour, time.getSecondOfMinute,
time.getMillisOfSecond * 1000 time.getMillisOfSecond * 1000
) )
@logger.debug? && @logger.debug("Date parsing done", :value => value, :timestamp => event["@timestamp"])
@logger.debug? && @logger.debug("Date parsing done", :value => value, :timestamp => event[@target])
rescue StandardError, JavaException => e rescue StandardError, JavaException => e
@logger.warn("Failed parsing date from field", :field => field, @logger.warn("Failed parsing date from field", :field => field,
:value => value, :exception => e) :value => value, :exception => e)