20 lines
502 B
Python
20 lines
502 B
Python
|
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
|