Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def __init__(self, host, port, **kwargs):
"""
Logging handler that transforms each record into GELF (graylog extended log format) and sends it over TCP.
:param host: GELF TCP input host
:param port: GELF TCP input port
"""
SocketHandler.__init__(self, host, port)
BaseHandler.__init__(self, **kwargs)
def __init__(self, host, port, compress=True, path='/gelf', timeout=5, **kwargs):
"""
Logging handler that transforms each record into GELF (graylog extended log format) and sends it over HTTP.
:param host: GELF HTTP input host
:param port: GELF HTTP input port
:param compress: compress message before sending it to the server or not
:param path: path of the HTTP input (http://docs.graylog.org/en/latest/pages/sending_data.html#gelf-via-http)
:param timeout: amount of seconds that HTTP client should wait before it discards the request
if the server doesn't respond
"""
LoggingHandler.__init__(self)
BaseHandler.__init__(self, compress=compress, **kwargs)
self.host = host
self.port = port
self.path = path
self.timeout = timeout
self.headers = {}
if compress:
self.headers['Content-Encoding'] = 'gzip,deflate'
def __init__(self, host, port, compress=True, chunk_size=1300, **kwargs):
"""
Logging handler that transforms each record into GELF (graylog extended log format) and sends it over UDP.
If message length exceeds chunk_size, the message splits into multiple chunks.
The number of chunks must be less than 128.
:param host: GELF UDP input host
:param port: GELF UDP input port
:param compress: compress message before sending it to the server or not
:param chunk_size: length of a chunk, should be less than the MTU (maximum transmission unit)
"""
DatagramHandler.__init__(self, host, port)
BaseHandler.__init__(self, compress=compress, **kwargs)
self.chunk_size = chunk_size