Timer for log service

Signed-off-by: Vishal Rana <vr@labstack.com>

Author: vishr

.gitignore

@@ -7,3 +7,4 @@ pip-selfcheck.json
 __pycache__
 dist
 *.egg-info
+*.pyc

Makefile

@@ -0,0 +1,3 @@
+publish:
+	python setup.py sdist bdist_wheel
+	twine upload dist/*

labstack/client.py

@@ -1,5 +1,6 @@
 import requests
 from .email import _Email
+from .log import _Log
 
 class Client():
   def __init__(self, api_key):
@@ -10,6 +11,12 @@ def __init__(self, api_key):
   def email(self):
     return _Email(self.interceptor)
 
+  def log(self):
+    log = _Log(self.interceptor)
+    log.app_id = self.app_id
+    log.app_name = self.app_name
+    return log
+
 class _Interceptor(requests.auth.AuthBase):
   def __init__(self, api_key):
     self.api_key = api_key

labstack/log.py

@@ -0,0 +1,100 @@
+import os
+import base64
+import json
+import time
+import threading
+import asyncio
+import requests
+import arrow
+from .common import API_URL
+
+LevelDebug = 0
+LevelInfo = 1
+LevelWarn = 2
+LevelError = 3
+LevelFatal = 4
+LevelOff = 5
+
+levels = {
+	LevelDebug: "DEBUG",
+	LevelInfo:  "INFO",
+	LevelWarn:  "WARN",
+	LevelError: "ERROR",
+	LevelFatal: "FATAL",
+}
+
+class _Log():
+  def __init__(self, interceptor):
+    self.path = '/log'
+    self.interceptor = interceptor
+    self._loop = None
+    self.entries = []
+    self.app_id = ''
+    self.app_name = '' 
+    self.tags = []
+    self.level = LevelInfo
+    self.batch_size = 60
+    self.dispatch_interval = 60
+
+  async def _schedule(self):
+    await self._dispatch()
+    await asyncio.sleep(self.dispatch_interval)
+  
+  async def _dispatch(self):
+    if len(self.entries) == 0:
+      return
+
+    r = requests.post(API_URL + self.path, auth=self.interceptor, data=json.dumps(self.entries))
+    if not 200 <= r.status_code < 300:
+      data = r.json()
+      raise LogError(data['code'], data['message'])
+
+  def debug(self, format, *argv):
+    self._log(LevelDebug, format, *argv)
+
+  def info(self, format, *argv):
+    self._log(LevelInfo, format, *argv)
+    
+  def warn(self, format, *argv):
+    self._log(LevelWarn, format, *argv)
+  
+  def error(self, format, *argv):
+    self._log(LevelError, format, *argv)
+    
+  def fatal(self, format, *argv):
+    self._log(LevelFatal, format, *argv)
+
+  def _log(self, level, format, *argv):
+    if level < self.level:
+      return
+
+    if self._loop is None:
+      self._loop = asyncio.new_event_loop()
+      asyncio.set_event_loop(self._loop)
+      self._loop.create_task(self._schedule())
+      threading.Thread(target=self._loop.run_forever).start()
+    
+    message = format.format(*argv)
+    self.entries.append({
+      'time': arrow.now().format('YYYY-MM-DDTHH:mm:ss.SSSZ'),
+		  'app_id': self.app_id,
+		  'app_name': self.app_name,
+		  'tags': self.tags,
+		  'level': levels[self.level],
+		  'message': message,
+    })
+
+    if len(self.entries) >= self.batch_size:
+      try:
+        self._dispatch()
+      except LogError as err:
+        print(err)
+    
+class LogError(Exception):
+  def __init__(self, code, message):
+    self.code = code
+    self.message = message
+
+  def __str__(self):
+    return 'log error, code={0}, message={1}'.format(self.code, self.message)
+  

setup.py

@@ -2,23 +2,19 @@
 
 setup(
   name='labstack',
-  version='0.0.1',
+  version='0.1.0',
   description='Official Python client library for the LabStack REST API',
   long_description='`<https://github.com/labstack/labstack-python>`_',
   keywords='labstack cube email log mqtt store',
   author='Vishal Rana',
   author_email='vr@labstack.com',
   license='MIT',
   install_requires=[
-    'requests==2.18.1'
+    'requests==2.18.1',
+    'arrow==0.10.0'
   ],
   classifiers=[
-      'Programming Language :: Python :: 2.6',
-      'Programming Language :: Python :: 2.7',
-      'Programming Language :: Python :: 3.2',
-      'Programming Language :: Python :: 3.3',
-      'Programming Language :: Python :: 3.4',
       'Programming Language :: Python :: 3.5',
       'Programming Language :: Python :: 3.6'
   ]
-)
+)