diff --git a/core/logstash.py b/core/logstash.py
new file mode 100644
index 0000000..aa5924b
--- /dev/null
+++ b/core/logstash.py
@@ -0,0 +1,19 @@
+import logstash
+import logging
+
+from json import dumps, loads
+import main
+from utils.logging.log import *
+
+logger = None
+def init_logstash():
+    global logger
+    logger = logging.getLogger('ingest')
+    logger.setLevel(logging.INFO)
+    logger.addHandler(logstash.TCPLogstashHandler(main.config["Logstash"]["Host"], int(main.config["Logstash"]["Port"]), version=1))
+
+def sendLogstashNotification(text):
+    if not logger == None:
+        logger.info(dumps(text))
+        return True
+    return False