python_logstash_tcp_udp_logging_with_extra_fields.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 TCP
11test_logger.addHandler(logstash.TCPLogstashHandler(host, 5000, version=1))
12# Or use UDP
13# test_logger.addHandler(logstash.LogstashHandler(host, 5959, version=1))
14
15test_logger.error('python-logstash: test error message.')
16test_logger.info('python-logstash: test info message.')
17test_logger.warning('python-logstash: test warning message.')
18
19# add extra field to logstash message
20extra = {
21    'test_string': 'python-logstash: test extra fields',
22    'test_boolean': True,
23    'test_dict': {'a': 1, 'b': 'c'},
24    'test_float': 1.23,
25    'test_integer': 123,
26    'test_list': [1, 2, '3'],
27}
28test_logger.info('python-logstash: test extra fields', extra=extra)