Class: LogStash::Codecs::CloudTrail

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/codecs/cloudtrail.rb

Overview

This is the base class for logstash codecs.

Instance Method Summary collapse

Instance Method Details

#decode(data) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/logstash/codecs/cloudtrail.rb', line 19

def decode(data)
  decoded = LogStash::Json.load(@converter.convert(data))
  decoded['Records'].each do |event|
    event['@timestamp'] = event.delete('eventTime')
    yield LogStash::Event.new(event)
  end
end

#register ⇒ Object 



13
14
15
16
 
# File 'lib/logstash/codecs/cloudtrail.rb', line 13

def register
  @converter = LogStash::Util::Charset.new(@charset)
  @converter.logger = @logger
end