sample logging application

logger.py

import logging
import sys
from logstash_async.handler import AsynchronousLogstashHandler
import time


host = 'localhost'

test_logger = logging.getLogger('python-logstash-logger')
test_logger.setLevel(logging.DEBUG)
test_logger.addHandler(logging.StreamHandler())
test_logger.addHandler(AsynchronousLogstashHandler(
    host, port=1337, database_path='db.sqlite3', transport='logstash_async.transport.TcpTransport'))



if __name__ == '__main__':
    i=0
    while True:
        test_logger.info('python-logstash-asnyc: %i', i)
        time.sleep(1)
        i = i+1
        if i > 20: break