Sha256: e101a1b475e18cb7cba88d051df53d68aa0e823eeace00d87ea6f66608622e7b
Contents?: true
Size: 1.4 KB
Versions: 6
Compression:
Stored size: 1.4 KB
Contents
# encoding: utf-8
require "logstash/codecs/base"
require "logstash/timestamp"
require "logstash/util"
class LogStash::Codecs::Msgpack < LogStash::Codecs::Base
config_name "msgpack"
milestone 1
config :format, :validate => :string, :default => nil
public
def register
require "msgpack"
end
public
def decode(data)
begin
# Msgpack does not care about UTF-8
event = LogStash::Event.new(MessagePack.unpack(data))
event["tags"] ||= []
if @format
event["message"] ||= event.sprintf(@format)
end
rescue => e
# Treat as plain text and try to do the best we can with it?
@logger.warn("Trouble parsing msgpack input, falling back to plain text",
:input => data, :exception => e)
event["message"] = data
event["tags"] ||= []
event["tags"] << "_msgpackparsefailure"
end
yield event
end # def decode
public
def encode(event)
# use normalize to make sure returned Hash is pure Ruby for
# MessagePack#pack which relies on pure Ruby object recognition
data = LogStash::Util.normalize(event.to_hash)
# timestamp is serialized as a iso8601 string
# merge to avoid modifying data which could have side effects if multiple outputs
@on_event.call(MessagePack.pack(data.merge(LogStash::Event::TIMESTAMP => event.timestamp.to_iso8601)))
end # def encode
end # class LogStash::Codecs::Msgpack
Version data entries
6 entries across 6 versions & 1 rubygems