flumelogger

Python library for sending log events to flume. Support both FlumeNG and FlumeOG (legacyThrift)

Installation

• pip install flumelogger

Usage

>>> import logging
>>> from flumelogger import handler

>>> fh = handler.FlumeHandler(host='my-flume-agent.example.com', port=9090, type='og',
...                           headers={'application': 'Skyline.Analyzer'})
>>> logger = logging.getLogger("AnalyzerLog")
>>> logger.setLevel(logging.DEBUG)
>>> logger.addHandler(fh)

>>> logger.info("python is cool")
>>>

Advanced Usage

Multiple hosts

>>> host = 'agent1.example.com,agent2.example.com'
>>> [...]

Force reconnect

>>> [...]
>>> fh.reconnect()