logstash-plugins / logstash-filter-zeromq Goto Github PK

input {
        stdin { codec => json }
}

filter {
#Decorate with user meta data
                mutate {
                        add_field => [ "metadata", '{"app":"myapp", "user":"myuser"}']
                }

                zeromq{
                        field => "metadata"
                        add_tag => [ "test" ] # results in test, test in [tags]
                        #add_tag => [ "test1", "test2" ] # results in test1, test2, test1, test2 in [tags]
                }

}

output {
        stdout { codec => rubydebug }
}

{
      "@version" => "1",
    "@timestamp" => "2015-11-27T04:01:08.114Z",
          "host" => "myhost",
      "metadata" => "{..lots of data filled in from zeromq...}",
          "tags" => [
        [0] "test",
        [1] "test"
    ]
}

context = zmq.Context()
consumer_receiver = context.socket(zmq.REP)
consumer_receiver.bind("tcp://0.0.0.0:5557")
while True:
    work = consumer_receiver.recv()
    consumer_receiver.send(work)

input {
    tcp { port => 5000 }
}

filter {
   zeromq {
        address => "tcp://192.168.59.3:5557"
   }
}

output {
    stdout { codec => rubydebug }
}

{:timestamp=>"2015-03-02T18:05:33.390000+0100", :message=>"0mq filter exception", :address=>"tcp://192.168.59.3:5557", :exception=>#<NoMethodError: undefined method `[]' for nil:NilClass>, :backtrace=>["/opt/logstash/lib/logstash/event.rb:163:in `overwrite'", "/opt/logstash/lib/logstash/filters/zeromq.rb:197:in `filter'", "(eval):23:in `initialize'", "org/jruby/RubyProc.java:271:in `call'", "/opt/logstash/lib/logstash/pipeline.rb:262:in `filter'", "/opt/logstash/lib/logstash/pipeline.rb:203:in `filterworker'", "/opt/logstash/lib/logstash/pipeline.rb:143:in `start_filters'"], :level=>:warn}
nil

logstash.noarch             1.4.2-1_2c0f5a1          @logstash-1.4
logstash-contrib.noarch     1.4.2-1_efd53ef          @logstash-1.4