add timeout to request, if an error is thrown print it. If buffer limit is reached and connection is faulty older messages will be dropped

Author: respectus

logdna/configs.py

@@ -2,7 +2,7 @@
     'CONTENT_TYPE': 'application/json; charset=UTF-8',
     'DEFAULT_REQUEST_TIMEOUT': 180000,
     'MS_IN_A_DAY': 86400000,
-    'MAX_REQUEST_TIMEOUT': 300000,
+    'MAX_REQUEST_TIMEOUT': 30,
     'MAX_LINE_LENGTH': 32000,
     'MAX_INPUT_LENGTH': 32,
     'FLUSH_INTERVAL': 5,

logdna/logdna.py

@@ -50,13 +50,15 @@ def flush(self):
         if not self.buf or len(self.buf) < 0:
             return
         data = {'e': 'ls', 'ls': self.buf}
-        resp = requests.post(url=defaults['LOGDNA_URL'], json=data, auth=('user', self.token), params={ 'hostname': self.hostname }, stream=True)
-        # print(self.buf)
-        self.buf = []
-        self.bufByteLength = 0
-        if self.flusher:
-            self.flusher.cancel()
-            self.flusher = None
+        try:
+            resp = requests.post(url=defaults['LOGDNA_URL'], json=data, auth=('user', self.token), params={ 'hostname': self.hostname }, stream=True, timeout=defaults['MAX_REQUEST_TIMEOUT'])
+            self.buf = []
+            self.bufByteLength = 0
+            if self.flusher:
+                self.flusher.cancel()
+                self.flusher = None
+        except requests.exceptions.RequestException as e:
+            print e
 
     def emit(self, record):
         record = record.__dict__

setup.py

@@ -2,12 +2,12 @@
 setup(
   name = 'logdna',
   packages = ['logdna'],
-  version = '1.0.4',
+  version = '1.0.6',
   description = 'A python package for sending logs to LogDNA',
   author = 'Answerbook Inc.',
   author_email = 'help@logdna.com',
   url = 'https://github.com/logdna/python',
-  download_url = 'https://github.com/logdna/python/tarball/1.0.3',
+  download_url = 'https://github.com/logdna/python/tarball/1.0.6',
   keywords = ['logdna', 'logging', 'logs', 'python', 'logdna.com', 'logger'],
   install_requires=[
     'requests',