Implement indexing into Apache Druid #1
|
@ -2,6 +2,7 @@ from core.logstash import sendLogstashNotification
|
||||||
from core.relay import sendRelayNotification
|
from core.relay import sendRelayNotification
|
||||||
from modules import userinfo
|
from modules import userinfo
|
||||||
from utils.dedup import dedup
|
from utils.dedup import dedup
|
||||||
|
import main
|
||||||
|
|
||||||
order = [
|
order = [
|
||||||
"type",
|
"type",
|
||||||
|
@ -74,5 +75,6 @@ def event(numName, c): # yes I'm using a short variable because otherwise it go
|
||||||
del c["muser"]
|
del c["muser"]
|
||||||
sortedKeys = {k: c[k] for k in order if k in c} # Sort dict keys according to order
|
sortedKeys = {k: c[k] for k in order if k in c} # Sort dict keys according to order
|
||||||
sortedKeys["src"] = "irc"
|
sortedKeys["src"] = "irc"
|
||||||
sendLogstashNotification(sortedKeys)
|
if main.config["Logstash"]["Enabled"]:
|
||||||
|
sendLogstashNotification(sortedKeys)
|
||||||
sendRelayNotification(sortedKeys)
|
sendRelayNotification(sortedKeys)
|
||||||
|
|
Loading…
Reference in New Issue