flume通过thrift协议收集日志-Python

#-*- coding: UTF-8 -*- __author__ = 'wangshuwei' import logging import logging.config #from flumelogger import handler logging.config.fileConfig('conf/logger.conf') def main(): logger = logging.getLogger("AnalyzerLog") #fh = handler.FlumeHandler(host='192.168.72.128', port=6667, type='ng',headers={'application': 'Skyline.Analyzer'}) #fh = handler.FlumeHandler(host='192.168.28.9', port=6667, type='ng',headers={'flag': 'PYTHON'}) #logger.addHandler(fh) logger.debug('debug message') logger.info('info message') logger.warn('warn message') logger.error('error message') logger.critical('critical message') logger.info("python is cool") main()