Python log handler for sending log events to flume

lsjostro lsjostro Last update: Jul 07, 2020

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()
Tags:

PRAGMA foreign_keys = off; BEGIN TRANSACTION; COMMIT TRANSACTION; PRAGMA foreign_keys = on;

Subscribe to our newsletter