Added a formatter

yoniabrahamy · yoniabrahamy · commit ad500d6f1e2c · 2019-05-05T21:00:29.000+03:00
diff --git a/logstash/formatter.py b/logstash/formatter.py
@@ -1,7 +1,7 @@
-import traceback
 import logging
 import socket
 import sys
+import traceback
 from datetime import datetime
 
 try:
@@ -140,3 +140,10 @@ def format(self, record):
             message.update(self.get_debug_fields(record))
 
         return self.serialize(message)
+
+
+# Added to get serialized strings instead of bytes
+class LogstashFormatterVersion2(LogstashFormatterVersion1):
+    @classmethod
+    def serialize(cls, message):
+        return json.dumps(message)
diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 setup(
     name='python-logstash',
     packages=['logstash'],
-    version='0.4.7',
+    version='0.4.8',
     description='Python logging handler for Logstash.',
     long_description=open('README.rst').read(),
     license='MIT',
