Add elk

Author: Sadisms

.env_meeting.example

@@ -16,4 +16,8 @@ FLASK_SECRET_KEY =
 
 NGROK_TOKEN =
 
-DEBUG =
+DEBUG =
+
+ELK_HOST    =
+ELK_PORT    =
+ELK_PREFIX  =

data/config.py

@@ -43,6 +43,11 @@
     'password': env.str('DB_PASS'),
 }
 
+ELK_CONFIG = {
+    'host': env.str('ELK_HOST'),
+    'port': env.str('ELK_PORT'),
+    'prefix': env.str('ELK_PREFIX')
+}
 
 def OAUTH_URL():
     with open('etc/oauth-server', 'r') as f:

requirements.txt

@@ -19,4 +19,6 @@ pytest~=7.1.3
 dateparser~=1.1.1
 pytimeparse~=1.1.8
 click~=8.1.3
-pyngrok~=5.1.0
+pyngrok~=5.1.0
+
+python-logstash-async==2.3.0

utils/logging.py

@@ -1,6 +1,9 @@
 import logging
 
-from data.config import DEBUG
+from logstash_async.handler import AsynchronousLogstashHandler
+from logstash_async.formatter import LogstashFormatter
+
+from data.config import DEBUG, ELK_CONFIG
 
 formatter = logging.Formatter('%(filename)-15s %(name)-8s LINE:%(lineno)-4d '
                               f'%(levelname)-8s [%(asctime)s] > %(message)s')
@@ -18,5 +21,16 @@ def create_logger(logger='', level=logging.INFO, console=True):
     return logger
 
 
+logstash_handler = AsynchronousLogstashHandler(ELK_CONFIG['host'], int(ELK_CONFIG['port']), database_path=None)
+logstash_handler.setFormatter(
+    LogstashFormatter(
+        message_type=f"{ELK_CONFIG['prefix']}",
+        extra_prefix=f"{ELK_CONFIG['prefix']}"
+    )
+)
+root = logging.getLogger('')
+root.setLevel(logging.INFO)
+root.addHandler(logstash_handler)
+
 create_logger('slack_bolt.AsyncApp')
 slack_logging = create_logger('meeting')