python log handler for fluent tcp transport

fluentd_handler.py

# -*- coding: utf-8 -*-

from logging.handlers import SocketHandler

import msgpack  # https://pypi.python.org/pypi/msgpack-python


class FluentdHandler(SocketHandler):

    def __init__(self, host='localhost', port=24224):
        super(FluentdHandler, self).__init__(host, port)

        self.packer = msgpack.Packer(encoding='utf-8')

    def makePickle(self, record):
        tag = '{0}.{1}'.format(record.name, record.funcName)

        data = {
            'level': record.levelname,
            'message': record.msg % record.args,
            'line': '{0}.{1}:{2}'.format(record.name, record.funcName, record.lineno),
        }

        return self.packer.pack([tag, record.created, data])