search

fluent-plugins-nursery / fluent-plugin-remote_syslog

Fluentd plugin for output to remote syslog serivce (e.g. Papertrail)
https://github.com/dlackty/fluent-plugin-remote_syslog
MIT License
68 stars 53 forks source link

add rewrite_tag_name mixin #2

Closed scalp42 closed 8 years ago

scalp42 commented 8 years ago

cc @dlackty for review

cc @y-ken for help :smile:

dlackty commented 8 years ago

@scalp42 Thank you!

scalp42 commented 8 years ago

@dlatcky I think the filter has to be after the record.each_pair

scalp42 commented 8 years ago 
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluent-plugin-remote_syslog-0.3.0/lib/fluent/plugin/out_remote_syslog.rb:45:in `block in emit'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event.rb:128:in `call'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event.rb:128:in `block in each'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event.rb:127:in `each'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event.rb:127:in `each'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluent-plugin-remote_syslog-0.3.0/lib/fluent/plugin/out_remote_syslog.rb:43:in `emit'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event_router.rb:152:in `emit'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event_router.rb:88:in `emit_stream'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/event_router.rb:79:in `emit'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:169:in `on_message'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:243:in `call'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:243:in `block in on_read_msgpack'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:242:in `feed_each'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:242:in `on_read_msgpack'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:228:in `call'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:228:in `on_read'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/cool.io-1.3.0/lib/cool.io/io.rb:123:in `on_readable'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/cool.io-1.3.0/lib/cool.io/io.rb:186:in `on_readable'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/cool.io-1.3.0/lib/cool.io/loop.rb:88:in `run_once'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/cool.io-1.3.0/lib/cool.io/loop.rb:88:in `run'
  2015-12-08 19:26:56 +0000 [warn]: /opt/td-agent/embedded/lib/ruby/gems/2.1.0/gems/fluentd-0.12.12/lib/fluent/plugin/in_forward.rb:91:in `run'
2015-12-08 19:26:56 +0000 [error]: forward error error=#<NoMethodError: undefined method `filter_record' for #<Fluent::RemoteSyslogOutput:0x007fa0867af250>> error_class=NoMethodError
  2015-12-08 19:26:56 +0000 [error]: suppressed same stacktrace
2015-12-08 19:27:03 +0000 [warn]: emit transaction failed: error_class=NoMethodError error="undefined method `filter_record' for #<Fluent::RemoteSyslogOutput:0x007fa0867af250>" tag="marathon.requestbin"
  2015-12-08 19:27:03 +0000 [warn]: suppressed same stacktrace
2015-12-08 19:27:03 +0000 [error]: forward error error=#<NoMethodError: undefined method `filter_record' for #<Fluent::RemoteSyslogOutput:0x007fa0867af250>> error_class=NoMethodError
  2015-12-08 19:27:03 +0000 [error]: suppressed same stacktrace