Wie Input-Wert auf benutzerdefinierten Filter bei Logstash erhalten

Question

Ich versuche Logstash und bisher, scheint wie ein großartiges Werkzeug, aber ich erreichte einen Punkt, wo ich einen benutzerdefinierten Filter in Python schreiben musste, und ich habe zu kämpfen um den Eingabewert zu erhalten. Es folgt meine logstash.conf

input { 
    stomp { 
     destination => "/topic/myevents" 
     host => "rabbitmq" 
     password => "guest" 
     user => "guest" 
     vhost => "/" 
     debug => true 
     port => 61613 
    } 
} 

filter { 
    ruby { 
     code => 'require "open3" 
       cmd = "/bin/events_filter.py {input should go here}" 
       stdin, stdout, stderr = Open3.popen3(cmd) 
       ' 
    } 
} 

output { 
    file { 
     path => "~/events.txt" 
    } 
} 

Kann mir jemand helfen, dies herauszufinden? Und wenn Sie irgendwelche Tipps oder bessere Möglichkeiten haben, externe Filter aufzurufen, würde ich es gerne wissen. Wow

Answer 1

,

anscheinend schafft Logstash ein Ereignisobjekt, das von meinem Ruby-Code zugegriffen werden kann (das wird als Argument für meinen Python-Code verwendet wird).

cmd = "/bin/events_filter.py #{event}" 

Damit kann ich auf das Eingabeereignis von meinem Python-Skript zugreifen! = D