Sha256: 913d8c6ca8e12de5887b4e1e46b8b73c37c2612337ed5b2258f598c2a4560c07
Contents?: true
Size: 514 Bytes
Versions: 6
Compression:
Stored size: 514 Bytes
Contents
# encoding: utf-8
require "logstash/codecs/base"
require "logstash/codecs/spool"
require "logstash/json"
# This is the base class for logstash codecs.
class LogStash::Codecs::CloudTrail < LogStash::Codecs::Spool
config_name "cloudtrail"
public
def decode(data)
super(LogStash::Json.load(data.force_encoding("UTF-8"))['Records']) do |event|
event['@timestamp'] = event.delete('eventTime')
yield LogStash::Event.new(event)
end
end # def decode
end # class LogStash::Codecs::CloudTrail
Version data entries
6 entries across 6 versions & 1 rubygems