import

Author: pyr

.gitignore

@@ -0,0 +1,20 @@
+# See http://help.github.com/ignore-files/ for more about ignoring files.
+#
+# If you find yourself ignoring temporary files generated by your text editor
+# or operating system, you probably want to add a global ignore instead:
+# git config --global core.excludesfile ~/.gitignore_global
+
+# Ignore bundler config
+/.bundle
+
+# Ignore the build directory
+/build
+/dist
+*.egg-info
+*.deb
+
+# Ignore Sass' cache
+/.sass-cache
+
+# python compiled files
+*.pyc

MANIFEST.in

@@ -0,0 +1,3 @@
+logstash_formatter: JSON logs for logstash
+==========================================
+

README.md

@@ -0,0 +1,50 @@
+import logging
+import socket
+import datetime
+import traceback as tb
+import json
+import sys
+
+class LogstashFormatter(logging.Formatter):
+    def __init__(self, source_host=None, defaults={}):
+
+        self.defaults = defaults
+        if source_host:
+            self.source_host = source_host
+        else:
+            try:
+                self.source_host = socket.gethostname()
+            except:
+                self.source_host = ""
+
+    def format(self, record):
+
+        fields = record.__dict__
+        
+        if isinstance(record.msg, dict):
+            fields.update(record.msg)
+            fields.pop('msg')
+            msg = ""
+        else:
+            msg = record.getMessage()
+
+        if 'msg' in fields:
+            fields.pop('msg')
+
+        if 'exc_info' in fields:
+            if fields['exc_info']:
+                formatted = tb.format_exception(*fields['exc_info'])
+                fields['exception'] = formatted
+            fields.pop('exc_info')
+
+        if 'exc_text' in fields and not fields['exc_text']:
+            fields.pop('exc_text')
+
+        logr = self.defaults.copy()
+        logr.update({'@message': msg,
+                     '@timestamp': datetime.datetime.now().isoformat(),
+                     '@source_host': self.source_host,
+                     '@fields': fields})
+
+        print(logr)
+        return json.dumps(logr)

logstash_formatter/__init__.py

@@ -0,0 +1,12 @@
+from setuptools import setup, find_packages
+
+setup(name='logstash_formatter',
+      version='0.5.0',
+      description='JSON formatter meant for logstash',
+      url='https://github.com/exoscale/python-logstash-formatter',
+      author='Exoscale',
+      author_email='[email protected]',
+      license='MIT',
+      packages=find_packages(),
+      include_package_data=True,
+      zip_safe=False)