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

Merge pull request #413 from AldenJole/feature/boundary-auto

Browse source 
Add auto to the boundary output.
This commit is contained in:
Jordan Sissel 2013-04-02 15:01:42 -07:00
commit 13f6e97302
1 changed files with 35 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

59
lib/logstash/outputs/boundary.rb
View file

@ -36,16 +36,23 @@ class LogStash::Outputs::Boundary < LogStash::Outputs::Base
config :end_time, :validate => :string
# Type
config :btype, :validate => :string, :default => "%{@message}"
config :btype, :validate => :string
# Sub-Type
config :bsubtype, :validate => :string, :default => "%{@type}"
config :bsubtype, :validate => :string
# Tags
# Set any custom tags for this event
# Default are the Logstash tags if any
config :btags, :validate => :array
# Auto
# If set to true, logstash will try to pull boundary fields out
# of the event. Any field explicitly set by config options will
# override these.
# ['type', 'subtype', 'creation_time', 'end_time', 'links', 'tags', 'loc']
config :auto, :validate => :bool, :default => false
public
def register
require "net/https"
@ -62,33 +69,32 @@ class LogStash::Outputs::Boundary < LogStash::Outputs::Base
def receive(event)
return unless output?(event)
boundary_event = Hash.new
if @start_time
boundary_event['start_time'] = event.sprintf(@start_time)
else
boundary_event['start_time'] = event.unix_timestamp.to_i
boundary_keys = ['type', 'subtype', 'creation_time', 'end_time', 'links', 'tags', 'loc']
boundary_event['start_time'] = event.sprintf(@start_time) if @start_time
boundary_event['end_time'] = event.sprintf(@end_time) if @end_time
boundary_event['type'] = event.sprintf(@btype) if @btype
boundary_event['subtype'] = event.sprintf(@bsubtype) if @bsubtype
boundary_event['tags'] = @btags.collect { |x| event.sprintf(x) } if @btags
if @auto
boundary_fields = event['@fields'].select { |k| boundary_keys.member? k }
boundary_event = boundary_fields.merge boundary_event
end
if @end_time
boundary_event['end_time'] = event.sprintf(@end_time)
else
boundary_event['end_time'] = event.unix_timestamp.to_i
end
boundary_event['type'] = event.sprintf(@btype)
boundary_event['sub_type'] = event.sprintf(@bsubtype) if @bsubtype
if @btags
tagz = @btags.collect {|x| event.sprintf(x) }
else
tagz = event.tags
end
boundary_event['tags'] = tagz if tagz
boundary_event = {
'type' => event.sprintf("%{message}"),
'subtype' => event.sprintf("%{type}"),
'start_time' => event.unix_timestamp.to_i,
'end_time' => event.unix_timestamp.to_i,
'links' => [],
'tags' => event.tags,
}.merge boundary_event
request = Net::HTTP::Post.new(@uri.path)
request.basic_auth(@api_key, '')
@logger.debug("Boundary event", :boundary_event => boundary_event)
begin
@ -98,7 +104,12 @@ class LogStash::Outputs::Boundary < LogStash::Outputs::Base
@logger.warn("Boundary convo", :request => request.inspect, :response => response.inspect)
raise unless response.code == '201'
rescue Exception => e
@logger.warn("Unhandled exception", :request => request.inspect, :response => response.inspect, :exception => e.inspect)
@logger.warn(
"Unhandled exception",
:request => request.inspect,
:response => response.inspect,
:exception => e.inspect
)
end
end # def receive
end