python_logstash_logger_udp_tcp_handler_quickstart.py

1import logging
2import logstash
3import sys
4
5host = 'localhost'
6
7test_logger = logging.getLogger('python-logstash-logger')
8test_logger.setLevel(logging.INFO)
9
10# Use LogstashHandler for UDP 
11test_logger.addHandler(logstash.LogstashHandler(host, 5959, version=1))
12
13# Or use TCPLogstashHandler for TCP
14# test_logger.addHandler(logstash.TCPLogstashHandler(host, 5959, version=1))
15
16test_logger.error('python-logstash: test error message.')
17test_logger.info('python-logstash: test info message.')
18test_logger.warning('python-logstash: test warning message.')
19
20# add extra field to logstash message
21extra = {
22    'test_string': 'python-logstash: hello with extra',
23    'test_boolean': True,
24    'test_dict': {'a': 1, 'b': 'c'},
25    'test_float': 1.23,
26    'test_integer': 123,
27    'test_list': [1, 2, '3'],
28}
29test_logger.info('python-logstash: test extra fields', extra=extra)