自己写一个插件

前面已经提过在运行 logstash 的时候,可以通过 --pluginpath 参数来加载自己写的插件。那么,插件又该怎么写呢?

插件格式

一个标准的 logstash 输入插件格式如下:

  1. require 'logstash/namespace'
  2. require 'logstash/inputs/base'
  3. class LogStash::Inputs::MyPlugin < LogStash::Inputs::Base
  4. config_name 'myplugin'
  5. milestone 1
  6. config :myoption_key, :validate => :string, :default => 'myoption_value'
  7. public def register
  8. end
  9. public def run(queue)
  10. end
  11. end

其中大多数语句在过滤器和输出阶段是共有的。

  • config_name 用来定义该插件写在 logstash 配置文件里的名字;
  • milestone 标记该插件的开发里程碑,一般为1,2,3,如果不再维护的,标记为 0;
  • config 可以定义很多个,即该插件在 logstash 配置文件中的可配置参数。logstash 很温馨的提供了验证方法,确保接收的数据是你期望的数据类型;
  • register logstash 在启动的时候运行的函数,一些需要常驻内存的数据,可以在这一步先完成。比如对象初始化,filters/ruby 插件中的 init 语句等。

小贴士

milestone 级别在 3 以下的,logstash 默认为不足够稳定,会在启动阶段,读取到该插件的时候,输出类似下面这样的一行提示信息,日志级别是 warn。这不代表运行出错!只是提示如果用户碰到 bug,欢迎提供线索。

{:timestamp=>”2015-02-06T10:37:26.312000+0800”, :message=>”Using milestone 2 input plugin ‘file’. This plugin should be stable, but if you see strange behavior, please let us know! For more information on plugin milestones, see http://logstash.net/docs/1.4.2-modified/plugin-milestones“, :level=>:warn}

插件的关键方法

输入插件独有的是 run 方法。在 run 方法中,必须实现一个长期运行的程序(最简单的就是 loop 指令)。然后在每次收到数据并处理成 event 之后,一定要调用 queue << event 语句。一个输入流程就算是完成了。

而如果是过滤器插件,对应修改成:

  1. require 'logstash/filters/base'
  2. class LogStash::Filters::MyPlugin < LogStash::Filters::Base
  3. public def filter(event)
  4. end
  5. end

输出插件则是:

  1. require 'logstash/outputs/base'
  2. class LogStash::Outputs::MyPlugin < LogStash::Outputs::Base
  3. public def receive(event)
  4. end
  5. end

另外,为了在终止进程的时候不遗失数据,建议都实现如下这个方法,只要实现了,logstash 在 shutdown 的时候就会自动调用:

  1. public def teardown
  2. end

推荐阅读